pxapi

Nov 9, 2023

Changes in this version

type ClientOption

+ func WithDirectAddr(directAddr string) ClientOption

+ func WithDirectCredsInsecure() ClientOption

+ func WithDisableTLSVerification(cloudAddr string) ClientOption

Oct 31, 2022

Changes in this version

type Client

+ func (c *Client) GetLatestOperatorVersion(ctx context.Context) (string, error)

+ func (c *Client) GetLatestVizierVersion(ctx context.Context) (string, error)

type VizierClient

+ func (v *VizierClient) GenerateOTelScript(ctx context.Context, pxl string) (string, error)

Apr 1, 2022

Changes in this version

type VizierStatus

+ const VizierStatusDegraded

Aug 16, 2021

Changes in this version

type ClientOption

+ func WithE2EEncryption(enabled bool) ClientOption

Jul 13, 2021

Changes in this version

+ func ProtoFromUUIDStrOrNil(u string) *uuidpb.UUID

+ func ProtoToUUIDStr(pb *uuidpb.UUID) string

+ type Client struct

+ func NewClient(ctx context.Context, opts ...ClientOption) (*Client, error)

+ func (c *Client) CreateAPIKey(ctx context.Context, desc string) (*cloudpb.APIKey, error)

+ func (c *Client) CreateDeployKey(ctx context.Context, desc string) (*cloudpb.DeploymentKey, error)

+ func (c *Client) DeleteAPIKey(ctx context.Context, id string) error

+ func (c *Client) GetVizierInfo(ctx context.Context, clusterID string) (*VizierInfo, error)

+ func (c *Client) ListViziers(ctx context.Context) ([]*VizierInfo, error)

+ func (c *Client) NewVizierClient(ctx context.Context, vizierID string) (*VizierClient, error)

+ type ClientOption func(client *Client)

+ func WithAPIKey(auth string) ClientOption

+ func WithBearerAuth(auth string) ClientOption

+ func WithCloudAddr(cloudAddr string) ClientOption

+ type ResultsStats struct

+ AcceptedBytes int64

+ BytesProcessed int64

+ CompilationTime time.Duration

+ ExecutionTime time.Duration

+ RecordsProcessed int64

+ TotalBytes int64

+ type ScriptResults struct

+ func (s *ScriptResults) Close() error

+ func (s *ScriptResults) Stats() *ResultsStats

+ func (s *ScriptResults) Stream() error

+ type TableMuxer interface

+ AcceptTable func(ctx context.Context, metadata types.TableMetadata) (TableRecordHandler, error)

+ type TableRecordHandler interface

+ HandleDone func(ctx context.Context) error

+ HandleInit func(ctx context.Context, metadata types.TableMetadata) error

+ HandleRecord func(ctx context.Context, record *types.Record) error

+ type VizierClient struct

+ func (v *VizierClient) ExecuteScript(ctx context.Context, pxl string, mux TableMuxer) (*ScriptResults, error)

+ type VizierInfo struct

+ DirectAccess bool

+ ID string

+ Name string

+ Status VizierStatus

+ Version string

+ type VizierStatus string

+ const VizierStatusDisconnected

+ const VizierStatusHealthy

+ const VizierStatusUnhealthy

+ const VizierStatusUnknown