client

Jun 14, 2024

Changes in this version

type Spec

+ TlsEnabled bool

+ TlsInsecureSkipVerify bool

+ TlsServerName string

Jan 23, 2024

Changes in this version

type Spec

+ CloseTimeout configtype.Duration

+ func (s *Spec) SetDefaults()

Jan 17, 2024

Changes in this version

type Spec

+ MaxCallRecvMsgSize *int

+ MaxCallSendMsgSize *int

Jan 2, 2024

Changes in this version

+ func New(ctx context.Context, logger zerolog.Logger, specBytes []byte, ...) (plugin.Client, error)

+ type AuthHandler struct

+ func NewAuthHandler(handshake, token string) *AuthHandler

+ func (c *AuthHandler) Authenticate(_ context.Context, conn flight.AuthConn) error

+ func (c *AuthHandler) GetToken(context.Context) (string, error)

+ type Client struct

+ func (c *Client) Close(context.Context) error

+ func (c *Client) DeleteRecord(ctx context.Context, msg *message.WriteDeleteRecord) error

+ func (c *Client) DeleteStale(ctx context.Context, msg *message.WriteDeleteStale) error

+ func (c *Client) Insert(ctx context.Context, msg *message.WriteInsert) error

+ func (c *Client) MigrateTable(ctx context.Context, msg *message.WriteMigrateTable) error

+ func (c *Client) Read(ctx context.Context, table *schema.Table, res chan<- arrow.Record) error

+ func (c *Client) Write(ctx context.Context, messages <-chan message.WriteMessage) error

+ type Spec struct

+ Addr string

+ Handshake string

+ Token string