client

package

v0.0.0-...-c987097 Latest Latest Go to latest Published: May 22, 2026 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation ¶

Package client provides client methods to communicate with ACS.

This section is empty.

This section is empty.

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

Notify sends an event notification on ACS.

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

Send sends a message on ACS.

func SendMessage(ctx context.Context, labels map[string]string, msg proto.Message) (*acpb.SendAgentMessageResponse, error)

SendMessage sends a message to ACS and waits for response. This is normally used for sending metrics to ACS.

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

Watch checks for a new message from ACS and returns.

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

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

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.