Documentation ¶
Index ¶
- Variables
- func MakeBinaryRecords() []arrow.Record
- func MakePrimitiveRecords() []arrow.Record
- type MockDataProxy
- func (m *MockDataProxy) DoGet(tkt *flight.Ticket, fs flight.FlightService_DoGetServer) error
- func (m *MockDataProxy) DoPut(stream flight.FlightService_DoPutServer) error
- func (m *MockDataProxy) GetFlightInfo(ctx context.Context, request *flight.FlightDescriptor) (*flight.FlightInfo, error)
- func (m *MockDataProxy) Start() error
Constants ¶
This section is empty.
Variables ¶
Functions ¶
func MakeBinaryRecords ¶
func MakePrimitiveRecords ¶
Types ¶
type MockDataProxy ¶
type MockDataProxy struct { Addr string flight.BaseFlightServer // contains filtered or unexported fields }
func NewMockDataProxy ¶
func NewMockDataProxy(addr string) *MockDataProxy
func (*MockDataProxy) DoGet ¶
func (m *MockDataProxy) DoGet(tkt *flight.Ticket, fs flight.FlightService_DoGetServer) error
func (*MockDataProxy) DoPut ¶
func (m *MockDataProxy) DoPut(stream flight.FlightService_DoPutServer) error
func (*MockDataProxy) GetFlightInfo ¶
func (m *MockDataProxy) GetFlightInfo(ctx context.Context, request *flight.FlightDescriptor) (*flight.FlightInfo, error)
func (*MockDataProxy) Start ¶
func (m *MockDataProxy) Start() error
Click to show internal directories.
Click to hide internal directories.