event_state

Documentation

Index

• Variables
• func RegisterEventsRecorderServer(s *grpc.Server, srv EventsRecorderServer)
• type AggregatorClient
  • func NewAggregatorClient(aggregAddr string) (*AggregatorClient, error)
  • func (ac *AggregatorClient) Close()
  • func (ac *AggregatorClient) Publish(rl *EventsRecordList) error
• 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 EventsRecordList
  • func (*EventsRecordList) Descriptor() ([]byte, []int)
  • func (m *EventsRecordList) GetItems() []*EventsRecord
  • func (*EventsRecordList) ProtoMessage()
  • func (m *EventsRecordList) Reset()
  • func (m *EventsRecordList) String() string
  • func (m *EventsRecordList) XXX_DiscardUnknown()
  • func (m *EventsRecordList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *EventsRecordList) XXX_Merge(src proto.Message)
  • func (m *EventsRecordList) XXX_Size() int
  • func (m *EventsRecordList) 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() uint32
  • 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 *EventsRecordList) (*RecordReply, error)

Variables

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

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

Functions

func RegisterEventsRecorderServer

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

Types

type AggregatorClient

type AggregatorClient struct {
	// contains filtered or unexported fields
}

func NewAggregatorClient

func NewAggregatorClient(aggregAddr string) (*AggregatorClient, error)

func (*AggregatorClient) Close

func (ac *AggregatorClient) Close()

func (*AggregatorClient) Publish

func (ac *AggregatorClient) Publish(rl *EventsRecordList) error

type EventsRecord

type EventsRecord struct {
	Events               map[string]*timestamp.Timestamp `` /* 153-byte string literal not displayed */
	Type                 EventsRecord_Type               `protobuf:"varint,2,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 EventsRecordList

type EventsRecordList struct {
	Items                []*EventsRecord `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*EventsRecordList) Descriptor

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

func (*EventsRecordList) GetItems

func (m *EventsRecordList) GetItems() []*EventsRecord

func (*EventsRecordList) ProtoMessage

func (*EventsRecordList) ProtoMessage()

func (*EventsRecordList) Reset

func (m *EventsRecordList) Reset()

func (*EventsRecordList) String

func (m *EventsRecordList) String() string

func (*EventsRecordList) XXX_DiscardUnknown

func (m *EventsRecordList) XXX_DiscardUnknown()

func (*EventsRecordList) XXX_Marshal

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

func (*EventsRecordList) XXX_Merge

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

func (*EventsRecordList) XXX_Size

func (m *EventsRecordList) XXX_Size() int

func (*EventsRecordList) XXX_Unmarshal

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

type EventsRecord_Type

type EventsRecord_Type int32

const (
	EventsRecord_UNKNOWN  EventsRecord_Type = 0
	EventsRecord_SENT     EventsRecord_Type = 1
	EventsRecord_ACCEPTED 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 *EventsRecordList, 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, *EventsRecordList) (*RecordReply, error)
}

EventsRecorderServer is the server API for EventsRecorder service.

type RecordReply

type RecordReply struct {
	Count                uint32   `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() uint32

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 *EventsRecordList) (*RecordReply, error)