client

Documentation

Overview

Package client provides client methods to communicate with ACS.

Index

• func Notify(ctx context.Context, event *acmpb.PluginEventMessage) error
• func Send(ctx context.Context, labels map[string]string, msg proto.Message) error
• func Watch(ctx context.Context) (*acpb.MessageBody, error)
• type ConnectionInterface
• type ContextKey

Functions

func Notify

func Notify(ctx context.Context, event *acmpb.PluginEventMessage) error

Notify sends an event notification on ACS.

func Send

func Send(ctx context.Context, labels map[string]string, msg proto.Message) error

Send sends a message on ACS.

func Watch

func Watch(ctx context.Context) (*acpb.MessageBody, error)

Watch checks for a new message from ACS and returns.

Types

type ConnectionInterface

type ConnectionInterface interface {
	SendMessage(msg *acpb.MessageBody) error
	Receive() (*acpb.MessageBody, error)
}

ConnectionInterface is the minimum interface required by Agent to communicate with ACS.

type ContextKey

type ContextKey string

ContextKey is the context key type to use for overriding.

const OverrideConnection ContextKey = "override_connection"

OverrideConnection is the key for context to override client connection.