grpc

Documentation

Index

• func NewAgentOptions(grpcOptions *GRPCOptions, clusterName, agentID string) *options.CloudEventsAgentOptions
• func NewSourceOptions(gRPCOptions *GRPCOptions, sourceID string) *options.CloudEventsSourceOptions
• type GRPCConfig
• type GRPCOptions
  • func BuildGRPCOptionsFromFlags(configPath string) (*GRPCOptions, error)
  • func NewGRPCOptions() *GRPCOptions
  • func (o *GRPCOptions) GetCloudEventsProtocol(ctx context.Context, errorHandler func(error), clientOpts ...protocol.Option) (options.CloudEventsProtocol, error)
  • func (o *GRPCOptions) GetGRPCClientConn() (*grpc.ClientConn, error)

Functions

func NewAgentOptions

func NewAgentOptions(grpcOptions *GRPCOptions, clusterName, agentID string) *options.CloudEventsAgentOptions

func NewSourceOptions

func NewSourceOptions(gRPCOptions *GRPCOptions, sourceID string) *options.CloudEventsSourceOptions

Types

type GRPCConfig

type GRPCConfig struct {
	// URL is the address of the gRPC server (host:port).
	URL string `json:"url" yaml:"url"`
	// CAFile is the file path to a cert file for the gRPC server certificate authority.
	CAFile string `json:"caFile,omitempty" yaml:"caFile,omitempty"`
	// ClientCertFile is the file path to a client cert file for TLS.
	ClientCertFile string `json:"clientCertFile,omitempty" yaml:"clientCertFile,omitempty"`
	// ClientKeyFile is the file path to a client key file for TLS.
	ClientKeyFile string `json:"clientKeyFile,omitempty" yaml:"clientKeyFile,omitempty"`
	// TokenFile is the file path to a token file for authentication.
	TokenFile string `json:"tokenFile,omitempty" yaml:"tokenFile,omitempty"`
}

GRPCConfig holds the information needed to build connect to gRPC server as a given user.

type GRPCOptions

type GRPCOptions struct {
	URL            string
	CAFile         string
	ClientCertFile string
	ClientKeyFile  string
	TokenFile      string
}

GRPCOptions holds the options that are used to build gRPC client.

func BuildGRPCOptionsFromFlags

func BuildGRPCOptionsFromFlags(configPath string) (*GRPCOptions, error)

BuildGRPCOptionsFromFlags builds configs from a config filepath.

func NewGRPCOptions

func NewGRPCOptions() *GRPCOptions

func (*GRPCOptions) GetCloudEventsProtocol

func (o *GRPCOptions) GetCloudEventsProtocol(ctx context.Context, errorHandler func(error), clientOpts ...protocol.Option) (options.CloudEventsProtocol, error)

func (*GRPCOptions) GetGRPCClientConn

func (o *GRPCOptions) GetGRPCClientConn() (*grpc.ClientConn, error)