Documentation
¶
Overview ¶
Package proto is a generated protocol buffer package.
It is generated from these files:
event.proto
It has these top-level messages:
CloudEvent Result
Index ¶
- func RegisterEventHandlerServer(s *grpc.Server, srv EventHandlerServer)
- type CloudEvent
- func (*CloudEvent) Descriptor() ([]byte, []int)
- func (m *CloudEvent) GetContenttype() string
- func (m *CloudEvent) GetData() []byte
- func (m *CloudEvent) GetExtensions() map[string]string
- func (m *CloudEvent) GetId() string
- func (m *CloudEvent) GetSchemaurl() string
- func (m *CloudEvent) GetSource() string
- func (m *CloudEvent) GetSpecversion() string
- func (m *CloudEvent) GetTime() string
- func (m *CloudEvent) GetType() string
- func (*CloudEvent) ProtoMessage()
- func (m *CloudEvent) Reset()
- func (m *CloudEvent) String() string
- type EventHandlerClient
- type EventHandlerServer
- type Result
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterEventHandlerServer ¶
func RegisterEventHandlerServer(s *grpc.Server, srv EventHandlerServer)
Types ¶
type CloudEvent ¶
type CloudEvent struct { Specversion string `protobuf:"bytes,1,opt,name=specversion" json:"specversion,omitempty"` Type string `protobuf:"bytes,2,opt,name=type" json:"type,omitempty"` Source string `protobuf:"bytes,3,opt,name=source" json:"source,omitempty"` Id string `protobuf:"bytes,4,opt,name=id" json:"id,omitempty"` Time string `protobuf:"bytes,5,opt,name=time" json:"time,omitempty"` Schemaurl string `protobuf:"bytes,6,opt,name=schemaurl" json:"schemaurl,omitempty"` Contenttype string `protobuf:"bytes,7,opt,name=contenttype" json:"contenttype,omitempty"` Data []byte `protobuf:"bytes,8,opt,name=data,proto3" json:"data,omitempty"` Extensions map[string]string `` /* 140-byte string literal not displayed */ }
func (*CloudEvent) Descriptor ¶
func (*CloudEvent) Descriptor() ([]byte, []int)
func (*CloudEvent) GetContenttype ¶
func (m *CloudEvent) GetContenttype() string
func (*CloudEvent) GetData ¶
func (m *CloudEvent) GetData() []byte
func (*CloudEvent) GetExtensions ¶
func (m *CloudEvent) GetExtensions() map[string]string
func (*CloudEvent) GetId ¶
func (m *CloudEvent) GetId() string
func (*CloudEvent) GetSchemaurl ¶
func (m *CloudEvent) GetSchemaurl() string
func (*CloudEvent) GetSource ¶
func (m *CloudEvent) GetSource() string
func (*CloudEvent) GetSpecversion ¶
func (m *CloudEvent) GetSpecversion() string
func (*CloudEvent) GetTime ¶
func (m *CloudEvent) GetTime() string
func (*CloudEvent) GetType ¶
func (m *CloudEvent) GetType() string
func (*CloudEvent) ProtoMessage ¶
func (*CloudEvent) ProtoMessage()
func (*CloudEvent) Reset ¶
func (m *CloudEvent) Reset()
func (*CloudEvent) String ¶
func (m *CloudEvent) String() string
type EventHandlerClient ¶
type EventHandlerClient interface {
Handle(ctx context.Context, in *CloudEvent, opts ...grpc.CallOption) (*Result, error)
}
func NewEventHandlerClient ¶
func NewEventHandlerClient(cc *grpc.ClientConn) EventHandlerClient
type EventHandlerServer ¶
type EventHandlerServer interface {
Handle(context.Context, *CloudEvent) (*Result, error)
}
type Result ¶
type Result struct {
Status string `protobuf:"bytes,1,opt,name=status" json:"status,omitempty"`
}
func (*Result) Descriptor ¶
func (*Result) ProtoMessage ¶
func (*Result) ProtoMessage()
Click to show internal directories.
Click to hide internal directories.