rpc

Documentation

Index

• Constants
• type AgentEndpoint
  • func (ep *AgentEndpoint) Send(action *agent.Action)
• type EndpointState

Constants

const (
	// TransportType is the name of this transport
	TransportType = "grpc"
	// Connected indicates a connected endpoint
	Connected = EndpointState(iota)
	// Disconnected indicates a disconnected endpoint
	Disconnected
)

Types

type AgentEndpoint

type AgentEndpoint struct {
	// contains filtered or unexported fields
}

AgentEndpoint represents the agent side of a data mover connection

func (*AgentEndpoint) Send

func (ep *AgentEndpoint) Send(action *agent.Action)

Send delivers an agent action to the backend

type EndpointState

type EndpointState int

EndpointState represents the connectedness state of an Endpoint