package
0.3.7
Repository: https://github.com/aliyun/aliyun-odps-go-sdk.git
Documentation: pkg.go.dev

# Functions

AuthFromContext will return back whatever object was returned from `IsValid` for a given request context allowing handlers to retrieve identifying information for the current request for use.
No description provided by the author
CreateServerBasicAuthMiddleware returns a ServerMiddleware that can be passed to NewServerWithMiddleware in order to automatically add interceptors which will properly enforce auth validation as per the passed in BasicAuthValidator.
CreateServerBearerTokenAuthInterceptors returns grpc interceptors for basic auth handling via bearer tokens.
No description provided by the author
DeserializeSchema takes the schema bytes from FlightInfo or SchemaResult and returns the deserialized arrow schema.
NewClientWithMiddleware takes a slice of middlewares in addition to the auth and address which will be used by grpc and chained, the first middleware will be the outer most with the last middleware being the inner most wrapper around the actual call.
NewFlightClient takes in the address of the grpc server and an auth handler for the application-level handshake.
NewFlightServer takes in an auth handler for managing the handshake authentication and any grpc Server options desired, such as TLS certs and so on which will just be passed through to the underlying grpc server.
No description provided by the author
NewFlightServiceService creates a new FlightServiceService containing the implemented methods of the FlightService service in s.
NewRecordReader constructs an ipc reader using the flight data stream reader as the source of the ipc messages, opts passed will be passed to the underlying ipc.Reader such as ipc.WithSchema and ipc.WithAllocator.
NewRecordWriter can be used to construct a writer for arrow flight via the grpc stream handler to write flight data objects and write record batches to the stream.
NewServerWithMiddleware takes a slice of middleware which will be used by grpc and chained, the first middleware will be the outer most with the last middleware being the inner most wrapper around the actual call.
RegisterFlightServiceService registers a service implementation with a gRPC server.
SerializeSchema returns the serialized schema bytes for use in Arrow Flight protobuf messages.

# Constants

An opaque command to generate a dataset.
A named path that identifies a dataset.
Protobuf pattern, not used.

# Variables

No description provided by the author
Enum value maps for FlightDescriptor_DescriptorType.
Enum value maps for FlightDescriptor_DescriptorType.

# Structs

An opaque action specific for the service.
Describes an available action, including both the name used for execution along with a short description of the purpose of the action.
A message for doing simple auth.
No description provided by the author
A service specific expression that can be used to return a limited set of available Arrow Flight streams.
No description provided by the author
A batch of Arrow data as part of a stream of batches.
The name or tag for a Flight.
A particular stream or split associated with a flight.
The access coordinates for retrieval of a dataset.
FlightServiceService is the service API for FlightService service.
The request that a client provides to a server on handshake.
No description provided by the author
A location where a Flight service will accept retrieval of a particular stream given a ticket.
* The response message associated with the submission of a DoPut.
Reader is an ipc.Reader which also keeps track of the metadata from the FlightData messages as they come in, calling LatestAppMetadata will return the metadata bytes from the most recently read message.
An opaque result returned after executing an action.
Wrap the result of a getSchema call.
No description provided by the author
An opaque identifier that the service can use to retrieve a particular portion of a stream.
Writer is an ipc.Writer which also adds a WriteWithAppMetadata function in order to allow adding AppMetadata to the FlightData messages which are written.

# Interfaces

AuthConn wraps the stream from grpc for handshakes to simplify handling handshake request and response from the flight.proto forwarding just the payloads and errors instead of having to deal with the handshake request and response protos directly.
No description provided by the author
Client is an interface wrapped around the generated FlightServiceClient which is generated by grpc protobuf definitions.
ClientAuthHandler defines an interface for the Flight client to perform the authentication handshake.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
DataStreamReader is an interface for receiving flight data messages on a stream such as via grpc with Arrow Flight.
DataStreamWriter is an interface that represents an Arrow Flight stream writer that writes FlightData objects.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
FlightServiceClient is the client API for FlightService service.
Server is an interface for hiding some of the grpc specifics to make it slightly easier to manage a flight service, slightly modeled after the C++ implementation.
ServerAuthHandler defines an interface for the server to perform the handshake.
UnstableFlightServiceService is the service API for FlightService service.

# Type aliases

Describes what type of descriptor is defined.