event_state

Documentation

Index

• Variables
• func RegisterEventsRecorderServer(s *grpc.Server, srv EventsRecorderServer)
• type EventsRecord
  • func (*EventsRecord) Descriptor() ([]byte, []int)
  • func (m *EventsRecord) GetEvents() map[string]*timestamp.Timestamp
  • func (m *EventsRecord) GetType() EventsRecord_Type
  • func (*EventsRecord) ProtoMessage()
  • func (m *EventsRecord) Reset()
  • func (m *EventsRecord) String() string
  • func (m *EventsRecord) XXX_DiscardUnknown()
  • func (m *EventsRecord) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *EventsRecord) XXX_Merge(src proto.Message)
  • func (m *EventsRecord) XXX_Size() int
  • func (m *EventsRecord) XXX_Unmarshal(b []byte) error
• type EventsRecord_Type
  • func (EventsRecord_Type) EnumDescriptor() ([]byte, []int)
  • func (x EventsRecord_Type) String() string
• type EventsRecorderClient
  • func NewEventsRecorderClient(cc *grpc.ClientConn) EventsRecorderClient
• type EventsRecorderServer
• type RecordReply
  • func (*RecordReply) Descriptor() ([]byte, []int)
  • func (m *RecordReply) GetCount() uint64
  • func (*RecordReply) ProtoMessage()
  • func (m *RecordReply) Reset()
  • func (m *RecordReply) String() string
  • func (m *RecordReply) XXX_DiscardUnknown()
  • func (m *RecordReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *RecordReply) XXX_Merge(src proto.Message)
  • func (m *RecordReply) XXX_Size() int
  • func (m *RecordReply) XXX_Unmarshal(b []byte) error
• type UnimplementedEventsRecorderServer
  • func (*UnimplementedEventsRecorderServer) RecordEvents(ctx context.Context, req *EventsRecord) (*RecordReply, error)

Variables

var EventsRecord_Type_name = map[int32]string{
	0: "SENT",
	1: "ACCEPTED",
	2: "FAILED",
	3: "RECEIVED",
}

var EventsRecord_Type_value = map[string]int32{
	"SENT":     0,
	"ACCEPTED": 1,
	"FAILED":   2,
	"RECEIVED": 3,
}

Functions

func RegisterEventsRecorderServer

func RegisterEventsRecorderServer(s *grpc.Server, srv EventsRecorderServer)

Types

type EventsRecord

type EventsRecord struct {
	Events               map[string]*timestamp.Timestamp `` /* 153-byte string literal not displayed */
	Type                 EventsRecord_Type               `protobuf:"varint,4,opt,name=type,proto3,enum=event_state.EventsRecord_Type" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

func (*EventsRecord) Descriptor

func (*EventsRecord) Descriptor() ([]byte, []int)

func (*EventsRecord) GetEvents

func (m *EventsRecord) GetEvents() map[string]*timestamp.Timestamp

func (*EventsRecord) GetType

func (m *EventsRecord) GetType() EventsRecord_Type

func (*EventsRecord) ProtoMessage

func (*EventsRecord) ProtoMessage()

func (*EventsRecord) Reset

func (m *EventsRecord) Reset()

func (*EventsRecord) String

func (m *EventsRecord) String() string

func (*EventsRecord) XXX_DiscardUnknown

func (m *EventsRecord) XXX_DiscardUnknown()

func (*EventsRecord) XXX_Marshal

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

func (*EventsRecord) XXX_Merge

func (m *EventsRecord) XXX_Merge(src proto.Message)

func (*EventsRecord) XXX_Size

func (m *EventsRecord) XXX_Size() int

func (*EventsRecord) XXX_Unmarshal

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

type EventsRecord_Type

type EventsRecord_Type int32

const (
	EventsRecord_SENT     EventsRecord_Type = 0
	EventsRecord_ACCEPTED EventsRecord_Type = 1
	EventsRecord_FAILED   EventsRecord_Type = 2
	EventsRecord_RECEIVED EventsRecord_Type = 3
)

func (EventsRecord_Type) EnumDescriptor

func (EventsRecord_Type) EnumDescriptor() ([]byte, []int)

func (EventsRecord_Type) String

func (x EventsRecord_Type) String() string

type EventsRecorderClient

type EventsRecorderClient interface {
	RecordEvents(ctx context.Context, in *EventsRecord, opts ...grpc.CallOption) (*RecordReply, error)
}

EventsRecorderClient is the client API for EventsRecorder service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewEventsRecorderClient

func NewEventsRecorderClient(cc *grpc.ClientConn) EventsRecorderClient

type EventsRecorderServer

type EventsRecorderServer interface {
	RecordEvents(context.Context, *EventsRecord) (*RecordReply, error)
}

EventsRecorderServer is the server API for EventsRecorder service.

type RecordReply

type RecordReply struct {
	Count                uint64   `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RecordReply) Descriptor

func (*RecordReply) Descriptor() ([]byte, []int)

func (*RecordReply) GetCount

func (m *RecordReply) GetCount() uint64

func (*RecordReply) ProtoMessage

func (*RecordReply) ProtoMessage()

func (*RecordReply) Reset

func (m *RecordReply) Reset()

func (*RecordReply) String

func (m *RecordReply) String() string

func (*RecordReply) XXX_DiscardUnknown

func (m *RecordReply) XXX_DiscardUnknown()

func (*RecordReply) XXX_Marshal

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

func (*RecordReply) XXX_Merge

func (m *RecordReply) XXX_Merge(src proto.Message)

func (*RecordReply) XXX_Size

func (m *RecordReply) XXX_Size() int

func (*RecordReply) XXX_Unmarshal

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

type UnimplementedEventsRecorderServer

type UnimplementedEventsRecorderServer struct {
}

UnimplementedEventsRecorderServer can be embedded to have forward compatible implementations.

func (*UnimplementedEventsRecorderServer) RecordEvents

func (*UnimplementedEventsRecorderServer) RecordEvents(ctx context.Context, req *EventsRecord) (*RecordReply, error)