message

type Caller interface {
	CallComponent(Message) (interface{}, error)
}

type Message interface {
	Service() *service.Service
	Codec() codec.Codec
	Topic() string
	SetTopic(string)
	SetBody(v interface{}) error
	GetPayload() *Payload
	ToObject(v interface{}) error
	ToRemoteMessage() *RemoteMessage
}

type Option func(*Options)

type Options struct {
	Service *service.Service

	Payload *Payload
}

type Payload struct {
	Header               map[string]string `` /* 153-byte string literal not displayed */
	Body                 []byte            `protobuf:"bytes,3,opt,name=body,proto3" json:"body,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

type RemoteMessage struct {
	*service.Service `yaml:"service" json:"service"`
	*Payload         `yaml:"payload" json:"payload"`
}

type Request struct {
	Id                   string           `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Service              *service.Service `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"`
	Endpoint             string           `protobuf:"bytes,3,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	Payload              *Payload         `protobuf:"bytes,4,opt,name=payload,proto3" json:"payload,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

type Response struct {
	Body                 []byte            `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"`
	Header               map[string]string `` /* 153-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}