Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
Client is a GRPC client for the WorkflowMetadataSourceService.
func NewClient ¶
func NewClient(addr string, name string, opts ...ClientOption) (*Client, error)
NewClient creates a new GRPC client for the WorkflowMetadataSourceService. addr is the GRPC endpoint address (e.g., "localhost:50051"). name is a human-readable identifier for logging. opts are optional configuration options.
func NewClientWithOptions ¶
NewClientWithOptions creates a new GRPC client with custom dial options. This is useful for testing or when custom options are needed.
func (*Client) ListWorkflowMetadata ¶
func (c *Client) ListWorkflowMetadata(ctx context.Context, families []string, start, limit int64) ([]*pb.WorkflowMetadata, bool, error)
ListWorkflowMetadata fetches workflow metadata from the GRPC source. families is the list of DON families to filter workflows by. start is the pagination offset (0-indexed). limit is the maximum number of workflows to return per page. Returns workflows, hasMore flag indicating if more pages exist, and error.
type ClientOption ¶
type ClientOption func(*clientConfig)
ClientOption configures the Client
func WithJWTGenerator ¶
func WithJWTGenerator(generator auth.JWTGenerator) ClientOption
func WithTLS ¶
func WithTLS(enabled bool) ClientOption
Source Files