pubsub

Documentation

Overview

Package pubsub handles notifications of messages that should be sent back to the partner.

Index

• func Listen(ctx context.Context, cred string, h MessageHandler, projectID string, ...) error
• type Message
• type MessageHandler

Functions

func Listen

func Listen(ctx context.Context, cred string, h MessageHandler, projectID string, topic string, opts ...option.ClientOption) error

Listen listens for notifications from a pubsub subscription, uses the ids in the messages to fetch content with the HL7v2 API, then sends the message to the partner over MLLP.

Types

type Message

type Message interface {
	Ack()
	Data() []byte
	Attrs() map[string]string
}

Message represents a pubsub message.

type MessageHandler

type MessageHandler interface {
	Handle(Message)
}

MessageHandler is the interface for handling HL7v2 messages.