golego_engine_proto

package
v0.0.0-...-38decf1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 15, 2018 License: Apache-2.0 Imports: 6 Imported by: 0

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

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) Descriptor() ([]byte, []int)

func (*Event) GetData 

func (m *Event) GetData() map[string]string

func (*Event) GetId 

func (m *Event) GetId() string

func (*Event) GetMeta 

func (m *Event) GetMeta() map[string]string

func (*Event) GetParent 

func (m *Event) GetParent() *Event

func (*Event) GetSender 

func (m *Event) GetSender() int64

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) Reset 

func (m *Event) Reset()

func (*Event) String 

func (m *Event) String() string

func (*Event) XXX_DiscardUnknown 

func (m *Event) XXX_DiscardUnknown()

func (*Event) XXX_Marshal 

func (m *Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Event) XXX_Merge 

func (dst *Event) XXX_Merge(src proto.Message)

func (*Event) XXX_Size 

func (m *Event) XXX_Size() int

func (*Event) XXX_Unmarshal 

func (m *Event) XXX_Unmarshal(b []byte) error

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

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.