client

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

type ChannelIf interface {
	Close()
	WriteMessage(m proto.Message) error
	ReadMessage(m proto.Message, timeout time.Duration) error
}

type Client struct {
	Ch       *Channel
	FuncInfo FunctionInfo
}

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

type FunctionInfo interface {
	// NetAddress returns the IP address (or host name) and the default port of the function
	NetAddress() (host string, port int, err error)
	// FuncClass returns the class of the io4edge function: e.g. core/datalogger/controlio/ttynvt
	FuncClass() (class string, err error)
	// Security tells whether function channels use encryption (no/tls)
	Security() (security string, err error)
	// AuxPort returns the protocol of the aux port (tcp/udp) and the port
	// returns error if no aux port for function
	AuxPort() (protcol string, port int, err error)
	// AuxSchema returns the schema name of the aux channel
	// returns error if no aux port for function
	AuxSchemaID() (schemaID string, err error)
}

type If interface {
	Command(cmd proto.Message, res proto.Message, timeout time.Duration) error
	ReadMessage(res proto.Message, timeout time.Duration) error
}

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