Documentation
¶
Index ¶
- func CreateSub(ctx context.Context, client *pubsub.Client, subscription, topicId string) error
- func DeleteSub(ctx context.Context, client *pubsub.Client, subscription string) error
- func NewClient(ctx context.Context, projectName string) *pubsub.Client
- func PackPubsubMessage(msgs []*adsb.CompositeMsg, receiverName string) (*pubsub.Message, error)
- func PublishMsgs(ctx context.Context, client *pubsub.Client, topic, receiverName string, ...) error
- func RecreateSub(ctx context.Context, client *pubsub.Client, subscription, topic string) error
- func Setup(ctx context.Context, client *pubsub.Client, inTopic, inSub string) error
- func UnpackPubsubMessage(msg *pubsub.Message) ([]*adsb.CompositeMsg, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func PackPubsubMessage ¶
func PublishMsgs ¶
func PublishMsgs(ctx context.Context, client *pubsub.Client, topic, receiverName string, msgs []*adsb.CompositeMsg) error
This function runs in its own goroutine, so as not to hold up reading new messages
func RecreateSub ¶
func UnpackPubsubMessage ¶
func UnpackPubsubMessage(msg *pubsub.Message) ([]*adsb.CompositeMsg, error)
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.