agent

type Agent struct {
	L hclog.Logger

	LocalAddr string
	Token     string
	Labels    []string

	// RootCAs are the RootCAs to trust for connections to the hubs. If this
	// is not set, the defaults are used.
	RootCAs *x509.CertPool
	// contains filtered or unexported fields
}

type Conn struct {
	io.Reader
	io.WriteCloser

	Stream *yamux.Stream
	Labels *pb.LabelSet
	// contains filtered or unexported fields
}

type Label struct {
	Name, Value string
}

type Service struct {
	// The identifier for the service, populated when the service is added.
	Id *pb.ULID

	// The type identifer for the service. These identifiers are used by other
	// agents and hubs to find services of a particular type.
	Type string

	// The unique identifiers for the service. The labels can be anything and are
	// used by agents and hubs to locate services.
	Labels *pb.LabelSet

	// An additional metadata to attach to the service. Peer agents will be able to
	// see this metadata.
	Metadata map[string]string

	// The handler to invoke when the service is called.
	Handler ServiceHandler
}

type ServiceContext interface {
	wire.Context

	ProtocolId() string

	// Returns a reader that reads data on the connection
	BodyReader() io.Reader

	// Returns a writer than writes data on the connection
	BodyWriter() io.Writer
}

type ServiceHandler interface {
	HandleRequest(ctx context.Context, L hclog.Logger, sctx ServiceContext) error
}