client

package

v0.1.1 Latest Latest Go to latest Published: Dec 22, 2025 License: Unlicense Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type ErrForwardRequired struct {
	TargetNodeID string
	TargetAddr   string
}

ErrForwardRequired is returned when a request needs to be routed to another node

func IsForwardRequired(err error) *ErrForwardRequired

IsForwardRequired checks if an error is a "FORWARD_REQUIRED" error If success, returns the parsed error struct, otherwise nil

func (e *ErrForwardRequired) Error() string

type SmartClient struct {
	// contains filtered or unexported fields
}

SmartClient is a wrapper around flight.Client that handles strict sharding redirects

func NewSmartClient(addr string) (*SmartClient, error)

NewSmartClient creates a new smart client connected to the initial address

func (c *SmartClient) Close() error

Close closes all active connections

func (c *SmartClient) DoGet(ctx context.Context, ticket []byte) (flight.FlightService_DoGetClient, error)

DoGet performs a Flight DoGet with automatic redirection handling

func (c *SmartClient) DoPut(ctx context.Context, desc *flight.FlightDescriptor) (flight.FlightService_DoPutClient, error)

DoPut performs a Flight DoPut with automatic redirection handling (best-effort)

func (c *SmartClient) GetFlightInfo(ctx context.Context, desc *flight.FlightDescriptor) (*flight.FlightInfo, error)

GetFlightInfo gets flight info with redirect handling