pubsub

package
v0.0.23 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 12, 2023 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var NewSession = func(ctx context.Context, opt config.PubSub) (ISession, error) {
	options := make([]option.ClientOption, 0)
	if opt.EndPoint != "" {
		options = append(options, option.WithEndpoint(opt.EndPoint))
	}
	if opt.WithoutAuthentication {
		options = append(options, option.WithoutAuthentication())
	}
	if opt.GRPCInsecure {
		options = append(options, option.WithGRPCDialOption(grpc.WithTransportCredentials(insecure.NewCredentials())))
	}
	return newClient(ctx, fmt.Sprintf(`projects/%s`, opt.ProjectID), options...)
}

NewSession method

Functions

This section is empty.

Types

type ISession 

type ISession interface {
	Close() error
	Snapshot(id string) *pubsub.Snapshot
	Snapshots(ctx context.Context) *pubsub.SnapshotConfigIterator
	Subscription(id string) *pubsub.Subscription
	SubscriptionInProject(id, projectID string) *pubsub.Subscription
	Subscriptions(ctx context.Context) *pubsub.SubscriptionIterator
	CreateSubscription(ctx context.Context, id string, cfg pubsub.SubscriptionConfig) (*pubsub.Subscription, error)
	CreateTopic(ctx context.Context, topicID string) (*pubsub.Topic, error)
	CreateTopicWithConfig(ctx context.Context, topicID string, tc *pubsub.TopicConfig) (*pubsub.Topic, error)
	Topic(id string) *pubsub.Topic
	TopicInProject(id, projectID string) *pubsub.Topic
	Topics(ctx context.Context) *pubsub.TopicIterator
}

ISession interface

func NewExtendPubSubDatabase 

func NewExtendPubSubDatabase(logger *zap.Logger, opt config.PubSub) (ISession, func(), error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.