pubsub

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)

Functions

func CreateSub

func CreateSub(ctx context.Context, client *pubsub.Client, subscription, topicId string) error

func DeleteSub

func DeleteSub(ctx context.Context, client *pubsub.Client, subscription string) error

func NewClient

func NewClient(ctx context.Context, projectName string) *pubsub.Client

func PackPubsubMessage

func PackPubsubMessage(msgs []*adsb.CompositeMsg, receiverName string) (*pubsub.Message, error)

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 RecreateSub(ctx context.Context, client *pubsub.Client, subscription, topic string) error

func Setup

func Setup(ctx context.Context, client *pubsub.Client, inTopic, inSub string) error

func UnpackPubsubMessage

func UnpackPubsubMessage(msg *pubsub.Message) ([]*adsb.CompositeMsg, error)