pubsub

package

v0.1.111 Latest Latest Go to latest Published: Apr 26, 2025 License: Apache-2.0 Imports: 11 Imported by: 2

Details

This section is empty.

This section is empty.

This section is empty.

type Blackbox interface {
	contract.Base64Decoder
}

type Client interface {
	Blackbox
	contract.PubSubOperator
}

func NewClient(d Dependencies) (Client, error)

type DefaultTool struct {
	T *contract.Tool[Client]
}

func NewTool(c Client, opts contract.ToolOptions[Client]) *DefaultTool

func (d *DefaultTool) DecodePayload(ctx context.Context, r *http.Request) (contract.PubSubMessage, error)

DecodePayload extracts and decodes a Pub/Sub message from an HTTP request.

func (d *DefaultTool) MockPubSubPayload(ctx context.Context, msg contract.PubSubMessage, subscription string) (io.Reader, error)

MockPubSubPayload creates a mock Pub/Sub payload for testing purposes.

type Dependencies struct {
	M contract.Marshaler
	U contract.Unmarshaler
}

type Payload struct {
	Message      pubsub.Message `json:"message,omitempty"`
	Subscription string         `json:"subscription,omitempty"`
}

type PubSubMessageWrapper struct {
	Msg *pubsub.Message
}

func (p *PubSubMessageWrapper) GetAttributes() map[string]string

func (p *PubSubMessageWrapper) GetData() []byte

func (p *PubSubMessageWrapper) GetMessageID() string

func (p *PubSubMessageWrapper) GetPublishTime() time.Time