plugin

Documentation

Index

• Variables
• type Link
• type MessageQueue

Variables

var (
	// ErrSyncTLSConfigMissing certificate bidirectional authentication is required for connection with cloud
	ErrLinkTLSConfigMissing = fmt.Errorf("certificate bidirectional authentication is required for connection with cloud")
	ConfFile                string
)

Types

type Link

type Link interface {
	Receive() (<-chan *v1.Message, <-chan error)
	Request(msg *v1.Message) (*v1.Message, error)
	Send(msg *v1.Message) error
	IsAsyncSupported() bool
}

type MessageQueue

type MessageQueue interface {
	mq.MessageQueue
}