pubsub

Documentation

Index

• Constants
• func CloseAllSubscriberClientsByPubsubClientId(temp *PubsubClientId)
• func CloseAllTopicClientsByPubsubClientId(temp *PubsubClientId)
• func ClosePubsubClient(temp *PubsubClientId)
• func CloseSubscriptionClient(temp *SubscriberId)
• func CloseTopicClient(temp *PublisherId)
• func CreatePubsubClient(temp *PubsubClient)
• func CreateSubscriptionClient(temp *Subscriber)
• func CreateTopicClient(temp *Publisher)
• func GetPubsubClient(temp *PubsubClientId) (*pubsub.Client, error)
• func GetSubscriptionClient(temp *SubscriberId) (*pubsub.Subscription, error)
• func GetTopicClient(temp *PublisherId) (*pubsub.Topic, error)
• type PubConf
• type Publisher
• type PublisherId
• type Publishers
• type PubsubClient
• type PubsubClientId
• type PubsubClients
• type Service
• type SubConf
• type Subscriber
• type SubscriberId
• type Subscribers

Constants

const (
	ERROR_CLIENT_INSTANCE     = "pubsub_connection : failed to get the pubsub client"
	ERROR_PUB_CLIENT_INSTANCE = "pubsub_topic_connection : failed to get the pubsub topic client"
	ERROR_SUB_CLIENT_INSTANCE = "pubsub_subscription_connection : failed to get the pubsub subscription client"
)

Functions

func CloseAllSubscriberClientsByPubsubClientId

func CloseAllSubscriberClientsByPubsubClientId(temp *PubsubClientId)

func CloseAllTopicClientsByPubsubClientId

func CloseAllTopicClientsByPubsubClientId(temp *PubsubClientId)

func ClosePubsubClient

func ClosePubsubClient(temp *PubsubClientId)

ClosePubsubClient used to close the pubsub client instance

func CloseSubscriptionClient

func CloseSubscriptionClient(temp *SubscriberId)

func CloseTopicClient

func CloseTopicClient(temp *PublisherId)

func CreatePubsubClient

func CreatePubsubClient(temp *PubsubClient)

CreatePubsubClient used to create a new Pubsub Client connection

func CreateSubscriptionClient

func CreateSubscriptionClient(temp *Subscriber)

func CreateTopicClient

func CreateTopicClient(temp *Publisher)

func GetPubsubClient

func GetPubsubClient(temp *PubsubClientId) (*pubsub.Client, error)

GetPubsubClient used to get the pubsub client connection id

func GetSubscriptionClient

func GetSubscriptionClient(temp *SubscriberId) (*pubsub.Subscription, error)

func GetTopicClient

func GetTopicClient(temp *PublisherId) (*pubsub.Topic, error)

Types

type PubConf

type PubConf struct {
	PubsubClientId *PubsubClientId
	TopicId        string
}

type Publisher

type Publisher struct {
	Id   *PublisherId
	Once *sync.Once
	Conf *PubConf

	Err *error
	// contains filtered or unexported fields
}

type PublisherId

type PublisherId struct {
	Id string
}

type Publishers

type Publishers struct {
	// contains filtered or unexported fields
}

type PubsubClient

type PubsubClient struct {
	Id           *PubsubClientId
	MyContext    *context.Context
	Once         *sync.Once
	GcpProjectId string
	Opts         []option.ClientOption

	Err *error
	// contains filtered or unexported fields
}

type PubsubClientId

type PubsubClientId struct {
	Id string
}

type PubsubClients

type PubsubClients struct {
	// contains filtered or unexported fields
}

type Service

type Service struct{}

type SubConf

type SubConf struct {
	PubsubClientId      *PubsubClientId
	TopicSubscriptionId string
}

type Subscriber

type Subscriber struct {
	Id   *SubscriberId
	Once *sync.Once
	Conf *SubConf

	Err *error
	// contains filtered or unexported fields
}

type SubscriberId

type SubscriberId struct {
	Id string
}

type Subscribers

type Subscribers struct {
	// contains filtered or unexported fields
}