event_state

package
v0.36.1 Latest Latest
Warning

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

Go to latest
Published: Jan 26, 2023 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var EventsRecord_Type_name = map[int32]string{
	0: "UNKNOWN",
	1: "SENT",
	2: "ACCEPTED",
	3: "RECEIVED",
}
View Source
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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL