Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type ChipIngressClient ¶
type ChipIngressClient interface {
Ping(ctx context.Context) (string, error)
Publish(ctx context.Context, event ce.Event) (*pb.PublishResponse, error)
PublishBatch(ctx context.Context, events []ce.Event) (*pb.PublishResponse, error)
Close() error
}
func NewChipIngressClient ¶
func NewChipIngressClient(address string, opts ...Opt) (ChipIngressClient, error)
NewChipIngressClient creates a new client for the Chip Ingress service with optional configuration.
type Opt ¶
type Opt func(*chipIngressClientConfig)
Opt is a function that configures a ChipIngressClient
func WithLogger ¶
WithLogger sets the logger for the ChipIngress service.
func WithTransportCredentials ¶
func WithTransportCredentials(credentials credentials.TransportCredentials) Opt
WithTransportCredentials sets the transport credentials for the ChipIngress service.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.