gcp

Documentation

Index

• Variables
• func Init(conf *config.SystemConfig)

Variables

var OpenSubscription = func(ctx context.Context, topic string) (interface{}, error) {
	return pubsub.OpenSubscription(ctx, subscribeURI+topic+"-sub")
}

var OpenTopic = func(ctx context.Context, topic string) (interface{}, error) {
	return pubsub.OpenTopic(ctx, openTopicURI+topic)
}

Functions

func Init

func Init(conf *config.SystemConfig)