pubsub

package

v1.0.0-dev.170 Latest Latest Go to latest Published: May 6, 2025 License: MIT Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

func ConfigAdd(path string)

ConfigAdd registers shared API and gRPC configs under the given path.

func NewClient(ctx context.Context, plugins ...clientgrpc.Plugin) (*pubsub.Client, error)

NewClient creates a Pub/Sub client using default configuration.

func NewClientWithConfigPath(ctx context.Context, path string, plugins ...clientgrpc.Plugin) (*pubsub.Client, error)

NewClientWithConfigPath creates a Pub/Sub client from a specific config path.

func NewClientWithOptions(ctx context.Context, o *Options, plugins ...clientgrpc.Plugin) (*pubsub.Client, error)

NewClientWithOptions constructs a Pub/Sub client from Options.

type Options struct {
	APIOptions  apiv1.Options  `config:"apiOptions"`
	GRPCOptions grpcv1.Options `config:"grpcOptions"`
}

Options holds shared API/gRPC options for Pub/Sub.

func NewOptions() (*Options, error)

NewOptions loads Options from the default root.

func NewOptionsWithPath(path string) (*Options, error)

NewOptionsWithPath loads Options from the specified path.