chipingress

package

v0.7.1 Latest Latest Go to latest Published: Jul 28, 2025 License: MIT Imports: 14 Imported by: 1

Details

This section is empty.

This section is empty.

func NewChipIngressClient(address string, opts ...Opt) (pb.ChipIngressClient, error)

NewChipIngressClient creates a new client for the Chip Ingress service with optional configuration.

func NewEvent(domain, entity string, payload []byte, attributes map[string]any) (ce.Event, error)

NewEvent creates a new CloudEvent with the specified domain, entity, and payload.

func NewEventWithAttributes(domain, entity string, payload []byte, attributes map[string]any) (*cepb.CloudEvent, error)

NewEventWithAttributes creates a new CloudEvent with the specified domain, entity, payload, and optional attributes.

type HeaderProvider interface {
	GetHeaders() map[string]string
}

HeaderProvider defines an interface for providing headers

type Opt func(*chipIngressClientConfig)

Opt defines a function type for configuring the ChipIngressClient.

func WithAuthority(authority string) Opt

WithAuthority sets the authority for the gRPC connection.

func WithHeaderProvider(provider HeaderProvider) Opt

WithHeaderProvider sets a dynamic header provider for requests

func WithInsecureConnection() Opt

WithInsecureConnection configures the client to use an insecure connection (no TLS).

func WithTLSAndHTTP2(serverName string) Opt

Add a new option function for TLS with HTTP/2

func WithTransportCredentials(creds credentials.TransportCredentials) Opt

WithTransportCredentials sets the transport credentials for the ChipIngress service.

Path	Synopsis
pb
mocks