Documentation
¶
Overview ¶
Package golego_engine_proto is a generated protocol buffer package.
It is generated from these files:
event.proto
It has these top-level messages:
Event EventRequest EventResponse RollbackRequest RollbackResponse
Index ¶
- func RegisterEventServiceHandler(s server.Server, hdlr EventServiceHandler, opts ...server.HandlerOption)
- type Event
- func (*Event) Descriptor() ([]byte, []int)
- func (m *Event) GetData() map[string]string
- func (m *Event) GetId() string
- func (m *Event) GetMeta() map[string]string
- func (m *Event) GetParent() *Event
- func (m *Event) GetSender() int64
- func (*Event) ProtoMessage()
- func (m *Event) Reset()
- func (m *Event) String() string
- func (m *Event) XXX_DiscardUnknown()
- func (m *Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Event) XXX_Merge(src proto.Message)
- func (m *Event) XXX_Size() int
- func (m *Event) XXX_Unmarshal(b []byte) error
- type EventRequest
- func (*EventRequest) Descriptor() ([]byte, []int)
- func (m *EventRequest) GetEvent() *Event
- func (*EventRequest) ProtoMessage()
- func (m *EventRequest) Reset()
- func (m *EventRequest) String() string
- func (m *EventRequest) XXX_DiscardUnknown()
- func (m *EventRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *EventRequest) XXX_Merge(src proto.Message)
- func (m *EventRequest) XXX_Size() int
- func (m *EventRequest) XXX_Unmarshal(b []byte) error
- type EventResponse
- func (*EventResponse) Descriptor() ([]byte, []int)
- func (m *EventResponse) GetCode() int64
- func (m *EventResponse) GetEvents() []*Event
- func (m *EventResponse) GetMessage() string
- func (m *EventResponse) GetResults() map[string]string
- func (*EventResponse) ProtoMessage()
- func (m *EventResponse) Reset()
- func (m *EventResponse) String() string
- func (m *EventResponse) XXX_DiscardUnknown()
- func (m *EventResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *EventResponse) XXX_Merge(src proto.Message)
- func (m *EventResponse) XXX_Size() int
- func (m *EventResponse) XXX_Unmarshal(b []byte) error
- type EventService
- type EventServiceHandler
- type RollbackRequest
- func (*RollbackRequest) Descriptor() ([]byte, []int)
- func (m *RollbackRequest) GetEvent() *Event
- func (m *RollbackRequest) GetResults() map[string]string
- func (*RollbackRequest) ProtoMessage()
- func (m *RollbackRequest) Reset()
- func (m *RollbackRequest) String() string
- func (m *RollbackRequest) XXX_DiscardUnknown()
- func (m *RollbackRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *RollbackRequest) XXX_Merge(src proto.Message)
- func (m *RollbackRequest) XXX_Size() int
- func (m *RollbackRequest) XXX_Unmarshal(b []byte) error
- type RollbackResponse
- func (*RollbackResponse) Descriptor() ([]byte, []int)
- func (*RollbackResponse) ProtoMessage()
- func (m *RollbackResponse) Reset()
- func (m *RollbackResponse) String() string
- func (m *RollbackResponse) XXX_DiscardUnknown()
- func (m *RollbackResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *RollbackResponse) XXX_Merge(src proto.Message)
- func (m *RollbackResponse) XXX_Size() int
- func (m *RollbackResponse) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterEventServiceHandler ¶
func RegisterEventServiceHandler(s server.Server, hdlr EventServiceHandler, opts ...server.HandlerOption)
Types ¶
type Event ¶
type Event struct {
Id string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
Sender int64 `protobuf:"varint,2,opt,name=sender" json:"sender,omitempty"`
Meta map[string]string `` /* 128-byte string literal not displayed */
Data map[string]string `` /* 128-byte string literal not displayed */
Parent *Event `protobuf:"bytes,5,opt,name=parent" json:"parent,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*Event) Descriptor ¶
func (*Event) ProtoMessage ¶
func (*Event) ProtoMessage()
func (*Event) XXX_DiscardUnknown ¶
func (m *Event) XXX_DiscardUnknown()
func (*Event) XXX_Marshal ¶
func (*Event) XXX_Unmarshal ¶
type EventRequest ¶
type EventRequest struct {
Event *Event `protobuf:"bytes,1,opt,name=event" json:"event,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*EventRequest) Descriptor ¶
func (*EventRequest) Descriptor() ([]byte, []int)
func (*EventRequest) GetEvent ¶
func (m *EventRequest) GetEvent() *Event
func (*EventRequest) ProtoMessage ¶
func (*EventRequest) ProtoMessage()
func (*EventRequest) Reset ¶
func (m *EventRequest) Reset()
func (*EventRequest) String ¶
func (m *EventRequest) String() string
func (*EventRequest) XXX_DiscardUnknown ¶
func (m *EventRequest) XXX_DiscardUnknown()
func (*EventRequest) XXX_Marshal ¶
func (m *EventRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EventRequest) XXX_Merge ¶
func (dst *EventRequest) XXX_Merge(src proto.Message)
func (*EventRequest) XXX_Size ¶
func (m *EventRequest) XXX_Size() int
func (*EventRequest) XXX_Unmarshal ¶
func (m *EventRequest) XXX_Unmarshal(b []byte) error
type EventResponse ¶
type EventResponse struct {
Code int64 `protobuf:"varint,1,opt,name=code" json:"code,omitempty"`
Message string `protobuf:"bytes,2,opt,name=message" json:"message,omitempty"`
Events []*Event `protobuf:"bytes,3,rep,name=events" json:"events,omitempty"`
Results map[string]string `` /* 134-byte string literal not displayed */
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*EventResponse) Descriptor ¶
func (*EventResponse) Descriptor() ([]byte, []int)
func (*EventResponse) GetCode ¶
func (m *EventResponse) GetCode() int64
func (*EventResponse) GetEvents ¶
func (m *EventResponse) GetEvents() []*Event
func (*EventResponse) GetMessage ¶
func (m *EventResponse) GetMessage() string
func (*EventResponse) GetResults ¶
func (m *EventResponse) GetResults() map[string]string
func (*EventResponse) ProtoMessage ¶
func (*EventResponse) ProtoMessage()
func (*EventResponse) Reset ¶
func (m *EventResponse) Reset()
func (*EventResponse) String ¶
func (m *EventResponse) String() string
func (*EventResponse) XXX_DiscardUnknown ¶
func (m *EventResponse) XXX_DiscardUnknown()
func (*EventResponse) XXX_Marshal ¶
func (m *EventResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EventResponse) XXX_Merge ¶
func (dst *EventResponse) XXX_Merge(src proto.Message)
func (*EventResponse) XXX_Size ¶
func (m *EventResponse) XXX_Size() int
func (*EventResponse) XXX_Unmarshal ¶
func (m *EventResponse) XXX_Unmarshal(b []byte) error
type EventService ¶
type EventService interface {
// handle event
OnEvent(ctx context.Context, in *EventRequest, opts ...client.CallOption) (*EventResponse, error)
OnRollback(ctx context.Context, in *RollbackRequest, opts ...client.CallOption) (*RollbackResponse, error)
}
func NewEventService ¶
func NewEventService(name string, c client.Client) EventService
type EventServiceHandler ¶
type EventServiceHandler interface {
// handle event
OnEvent(context.Context, *EventRequest, *EventResponse) error
OnRollback(context.Context, *RollbackRequest, *RollbackResponse) error
}
type RollbackRequest ¶
type RollbackRequest struct {
Event *Event `protobuf:"bytes,1,opt,name=event" json:"event,omitempty"`
Results map[string]string `` /* 134-byte string literal not displayed */
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*RollbackRequest) Descriptor ¶
func (*RollbackRequest) Descriptor() ([]byte, []int)
func (*RollbackRequest) GetEvent ¶
func (m *RollbackRequest) GetEvent() *Event
func (*RollbackRequest) GetResults ¶
func (m *RollbackRequest) GetResults() map[string]string
func (*RollbackRequest) ProtoMessage ¶
func (*RollbackRequest) ProtoMessage()
func (*RollbackRequest) Reset ¶
func (m *RollbackRequest) Reset()
func (*RollbackRequest) String ¶
func (m *RollbackRequest) String() string
func (*RollbackRequest) XXX_DiscardUnknown ¶
func (m *RollbackRequest) XXX_DiscardUnknown()
func (*RollbackRequest) XXX_Marshal ¶
func (m *RollbackRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RollbackRequest) XXX_Merge ¶
func (dst *RollbackRequest) XXX_Merge(src proto.Message)
func (*RollbackRequest) XXX_Size ¶
func (m *RollbackRequest) XXX_Size() int
func (*RollbackRequest) XXX_Unmarshal ¶
func (m *RollbackRequest) XXX_Unmarshal(b []byte) error
type RollbackResponse ¶
type RollbackResponse struct {
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*RollbackResponse) Descriptor ¶
func (*RollbackResponse) Descriptor() ([]byte, []int)
func (*RollbackResponse) ProtoMessage ¶
func (*RollbackResponse) ProtoMessage()
func (*RollbackResponse) Reset ¶
func (m *RollbackResponse) Reset()
func (*RollbackResponse) String ¶
func (m *RollbackResponse) String() string
func (*RollbackResponse) XXX_DiscardUnknown ¶
func (m *RollbackResponse) XXX_DiscardUnknown()
func (*RollbackResponse) XXX_Marshal ¶
func (m *RollbackResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RollbackResponse) XXX_Merge ¶
func (dst *RollbackResponse) XXX_Merge(src proto.Message)
func (*RollbackResponse) XXX_Size ¶
func (m *RollbackResponse) XXX_Size() int
func (*RollbackResponse) XXX_Unmarshal ¶
func (m *RollbackResponse) XXX_Unmarshal(b []byte) error
Source Files
Click to show internal directories.
Click to hide internal directories.