eventgate

Feb 11, 2021

Changes in this version

type Event

+ Object *Object

+ func (x *Event) GetObject() *Object

type EventGateServiceClient

+ GetObject func(ctx context.Context, in *ObjectRef, opts ...grpc.CallOption) (*Object, error)

+ SearchEvents func(ctx context.Context, in *SearchOpts, opts ...grpc.CallOption) (*Events, error)

+ SetObject func(ctx context.Context, in *Object, opts ...grpc.CallOption) (*empty.Empty, error)

+ StreamEvents func(ctx context.Context, in *StreamOpts, opts ...grpc.CallOption) (EventGateService_StreamEventsClient, error)

type EventGateServiceServer

+ GetObject func(context.Context, *ObjectRef) (*Object, error)

+ SearchEvents func(context.Context, *SearchOpts) (*Events, error)

+ SetObject func(context.Context, *Object) (*empty.Empty, error)

+ StreamEvents func(*StreamOpts, EventGateService_StreamEventsServer) error

+ type EventGateService_StreamEventsClient interface

+ Recv func() (*Event, error)

+ type EventGateService_StreamEventsServer interface

+ Send func(*Event) error

+ type Object struct

+ Key string

+ Type string

+ Values *_struct.Struct

+ func (*Object) Descriptor() ([]byte, []int)

+ func (*Object) ProtoMessage()

+ func (this *Object) Validate() error

+ func (x *Object) GetKey() string

+ func (x *Object) GetType() string

+ func (x *Object) GetValues() *_struct.Struct

+ func (x *Object) ProtoReflect() protoreflect.Message

+ func (x *Object) Reset()

+ func (x *Object) String() string

+ type ObjectRef struct

+ Key string

+ Type string

+ func (*ObjectRef) Descriptor() ([]byte, []int)

+ func (*ObjectRef) ProtoMessage()

+ func (this *ObjectRef) Validate() error

+ func (x *ObjectRef) GetKey() string

+ func (x *ObjectRef) GetType() string

+ func (x *ObjectRef) ProtoReflect() protoreflect.Message

+ func (x *ObjectRef) Reset()

+ func (x *ObjectRef) String() string

+ type SearchOpts struct

+ Key string

+ Limit int64

+ Max int64

+ Min int64

+ Offset int64

+ Type string

+ func (*SearchOpts) Descriptor() ([]byte, []int)

+ func (*SearchOpts) ProtoMessage()

+ func (this *SearchOpts) Validate() error

+ func (x *SearchOpts) GetKey() string

+ func (x *SearchOpts) GetLimit() int64

+ func (x *SearchOpts) GetMax() int64

+ func (x *SearchOpts) GetMin() int64

+ func (x *SearchOpts) GetOffset() int64

+ func (x *SearchOpts) GetType() string

+ func (x *SearchOpts) ProtoReflect() protoreflect.Message

+ func (x *SearchOpts) Reset()

+ func (x *SearchOpts) String() string

+ type StreamOpts struct

+ Type string

+ func (*StreamOpts) Descriptor() ([]byte, []int)

+ func (*StreamOpts) ProtoMessage()

+ func (this *StreamOpts) Validate() error

+ func (x *StreamOpts) GetType() string

+ func (x *StreamOpts) ProtoReflect() protoreflect.Message

+ func (x *StreamOpts) Reset()

+ func (x *StreamOpts) String() string

type UnimplementedEventGateServiceServer

+ func (*UnimplementedEventGateServiceServer) GetObject(context.Context, *ObjectRef) (*Object, error)

+ func (*UnimplementedEventGateServiceServer) SearchEvents(context.Context, *SearchOpts) (*Events, error)

+ func (*UnimplementedEventGateServiceServer) SetObject(context.Context, *Object) (*empty.Empty, error)

+ func (*UnimplementedEventGateServiceServer) StreamEvents(*StreamOpts, EventGateService_StreamEventsServer) error

Feb 10, 2021

Changes in this version

+ type EventDetail struct

+ Channel string

+ Claims *_struct.Struct

+ Data *_struct.Struct

+ Id string

+ Metadata *_struct.Struct

+ Time *timestamp.Timestamp

+ func (*EventDetail) Descriptor() ([]byte, []int)

+ func (*EventDetail) ProtoMessage()

+ func (this *EventDetail) Validate() error

+ func (x *EventDetail) GetChannel() string

+ func (x *EventDetail) GetClaims() *_struct.Struct

+ func (x *EventDetail) GetData() *_struct.Struct

+ func (x *EventDetail) GetId() string

+ func (x *EventDetail) GetMetadata() *_struct.Struct

+ func (x *EventDetail) GetTime() *timestamp.Timestamp

+ func (x *EventDetail) ProtoReflect() protoreflect.Message

+ func (x *EventDetail) Reset()

+ func (x *EventDetail) String() string

+ type EventDetails struct

+ Events []*EventDetail

+ func (*EventDetails) Descriptor() ([]byte, []int)

+ func (*EventDetails) ProtoMessage()

+ func (this *EventDetails) Validate() error

+ func (x *EventDetails) GetEvents() []*EventDetail

+ func (x *EventDetails) ProtoReflect() protoreflect.Message

+ func (x *EventDetails) Reset()

+ func (x *EventDetails) String() string

Feb 9, 2021

Changes in this version

type Event

+ Claims *_struct.Struct

+ func (x *Event) GetClaims() *_struct.Struct

Feb 9, 2021

Changes in this version

type EventGateServiceClient

+ History func(ctx context.Context, in *HistoryOpts, opts ...grpc.CallOption) (*Events, error)

type EventGateServiceServer

+ History func(context.Context, *HistoryOpts) (*Events, error)

+ type Events struct

+ Events []*Event

+ func (*Events) Descriptor() ([]byte, []int)

+ func (*Events) ProtoMessage()

+ func (this *Events) Validate() error

+ func (x *Events) GetEvents() []*Event

+ func (x *Events) ProtoReflect() protoreflect.Message

+ func (x *Events) Reset()

+ func (x *Events) String() string

+ type HistoryOpts struct

+ Channel string

+ Limit int64

+ Max *timestamp.Timestamp

+ Min *timestamp.Timestamp

+ Offset int64

+ func (*HistoryOpts) Descriptor() ([]byte, []int)

+ func (*HistoryOpts) ProtoMessage()

+ func (this *HistoryOpts) Validate() error

+ func (x *HistoryOpts) GetChannel() string

+ func (x *HistoryOpts) GetLimit() int64

+ func (x *HistoryOpts) GetMax() *timestamp.Timestamp

+ func (x *HistoryOpts) GetMin() *timestamp.Timestamp

+ func (x *HistoryOpts) GetOffset() int64

+ func (x *HistoryOpts) ProtoReflect() protoreflect.Message

+ func (x *HistoryOpts) Reset()

+ func (x *HistoryOpts) String() string

type UnimplementedEventGateServiceServer

+ func (*UnimplementedEventGateServiceServer) History(context.Context, *HistoryOpts) (*Events, error)

Feb 5, 2021

Changes in this version

+ type ReceiveOpts struct

+ Channel string

+ ConsumerGroup string

+ func (*ReceiveOpts) Descriptor() ([]byte, []int)

+ func (*ReceiveOpts) ProtoMessage()

+ func (this *ReceiveOpts) Validate() error

+ func (x *ReceiveOpts) GetChannel() string

+ func (x *ReceiveOpts) GetConsumerGroup() string

+ func (x *ReceiveOpts) ProtoReflect() protoreflect.Message

+ func (x *ReceiveOpts) Reset()

+ func (x *ReceiveOpts) String() string

Feb 5, 2021

Changes in this version

+ type Event struct

+ Channel string

+ Data *_struct.Struct

+ Id string

+ Metadata map[string]string

+ Time *timestamp.Timestamp

+ func (*Event) Descriptor() ([]byte, []int)

+ func (*Event) ProtoMessage()

+ func (this *Event) Validate() error

+ func (x *Event) GetChannel() string

+ func (x *Event) GetData() *_struct.Struct

+ func (x *Event) GetId() string

+ func (x *Event) GetMetadata() map[string]string

+ func (x *Event) GetTime() *timestamp.Timestamp

+ func (x *Event) ProtoReflect() protoreflect.Message

+ func (x *Event) Reset()

+ func (x *Event) String() string

type Filter

+ Channel string

+ func (x *Filter) GetChannel() string

Feb 4, 2021

Changes in this version

type Filter

+ Matchers map[string]string

+ func (x *Filter) GetMatchers() map[string]string

Feb 3, 2021

Changes in this version

+ func RegisterEventGateServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

+ func RegisterEventGateServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client EventGateServiceClient) error

+ func RegisterEventGateServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)

+ func RegisterEventGateServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server EventGateServiceServer) error

+ func RegisterEventGateServiceServer(s *grpc.Server, srv EventGateServiceServer)

type CloudEvent

+ DataBase64 string

+ Datacontenttype string

+ EventgateAuth string

+ func (x *CloudEvent) GetDataBase64() string

+ func (x *CloudEvent) GetDatacontenttype() string

+ func (x *CloudEvent) GetEventgateAuth() string

type CloudEventInput

+ DataBase64 string

+ Datacontenttype string

+ func (x *CloudEventInput) GetDataBase64() string

+ func (x *CloudEventInput) GetDatacontenttype() string

+ type EventGateServiceClient interface

+ Receive func(ctx context.Context, in *Filter, opts ...grpc.CallOption) (EventGateService_ReceiveClient, error)

+ Request func(ctx context.Context, in *CloudEventInput, opts ...grpc.CallOption) (*CloudEvent, error)

+ Send func(ctx context.Context, in *CloudEventInput, opts ...grpc.CallOption) (*empty.Empty, error)

+ func NewEventGateServiceClient(cc grpc.ClientConnInterface) EventGateServiceClient

+ type EventGateServiceServer interface

+ Receive func(*Filter, EventGateService_ReceiveServer) error

+ Request func(context.Context, *CloudEventInput) (*CloudEvent, error)

+ Send func(context.Context, *CloudEventInput) (*empty.Empty, error)

+ type EventGateService_ReceiveClient interface

+ Recv func() (*CloudEvent, error)

+ type EventGateService_ReceiveServer interface

+ Send func(*CloudEvent) error

+ type Filter struct

+ Source string

+ Specversion string

+ Subject string

+ Type string

+ func (*Filter) Descriptor() ([]byte, []int)

+ func (*Filter) ProtoMessage()

+ func (this *Filter) Validate() error

+ func (x *Filter) GetSource() string

+ func (x *Filter) GetSpecversion() string

+ func (x *Filter) GetSubject() string

+ func (x *Filter) GetType() string

+ func (x *Filter) ProtoReflect() protoreflect.Message

+ func (x *Filter) Reset()

+ func (x *Filter) String() string

+ type UnimplementedEventGateServiceServer struct

+ func (*UnimplementedEventGateServiceServer) Receive(*Filter, EventGateService_ReceiveServer) error

+ func (*UnimplementedEventGateServiceServer) Request(context.Context, *CloudEventInput) (*CloudEvent, error)

+ func (*UnimplementedEventGateServiceServer) Send(context.Context, *CloudEventInput) (*empty.Empty, error)

Feb 2, 2021

Changes in this version

type CloudEvent

+ Dataschema string

+ func (x *CloudEvent) GetDataschema() string

type CloudEventInput

+ Dataschema string

+ func (x *CloudEventInput) GetDataschema() string

Feb 2, 2021

Changes in this version

+ var File_schema_proto protoreflect.FileDescriptor

+ func RegisterCloudEventsServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

+ func RegisterCloudEventsServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client CloudEventsServiceClient) error

+ func RegisterCloudEventsServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)

+ func RegisterCloudEventsServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server CloudEventsServiceServer) error

+ func RegisterCloudEventsServiceServer(s *grpc.Server, srv CloudEventsServiceServer)

+ type CloudEvent struct

+ Attributes *_struct.Struct

+ Data *_struct.Struct

+ Id string

+ Source string

+ Specversion string

+ Subject string

+ Time *timestamp.Timestamp

+ Type string

+ func (*CloudEvent) Descriptor() ([]byte, []int)

+ func (*CloudEvent) ProtoMessage()

+ func (this *CloudEvent) Validate() error

+ func (x *CloudEvent) GetAttributes() *_struct.Struct

+ func (x *CloudEvent) GetData() *_struct.Struct

+ func (x *CloudEvent) GetId() string

+ func (x *CloudEvent) GetSource() string

+ func (x *CloudEvent) GetSpecversion() string

+ func (x *CloudEvent) GetSubject() string

+ func (x *CloudEvent) GetTime() *timestamp.Timestamp

+ func (x *CloudEvent) GetType() string

+ func (x *CloudEvent) ProtoReflect() protoreflect.Message

+ func (x *CloudEvent) Reset()

+ func (x *CloudEvent) String() string

+ type CloudEventInput struct

+ Attributes *_struct.Struct

+ Data *_struct.Struct

+ Source string

+ Specversion string

+ Subject string

+ Type string

+ func (*CloudEventInput) Descriptor() ([]byte, []int)

+ func (*CloudEventInput) ProtoMessage()

+ func (this *CloudEventInput) Validate() error

+ func (x *CloudEventInput) GetAttributes() *_struct.Struct

+ func (x *CloudEventInput) GetData() *_struct.Struct

+ func (x *CloudEventInput) GetSource() string

+ func (x *CloudEventInput) GetSpecversion() string

+ func (x *CloudEventInput) GetSubject() string

+ func (x *CloudEventInput) GetType() string

+ func (x *CloudEventInput) ProtoReflect() protoreflect.Message

+ func (x *CloudEventInput) Reset()

+ func (x *CloudEventInput) String() string

+ type CloudEventsServiceClient interface

+ Receive func(ctx context.Context, in *ReceiveRequest, opts ...grpc.CallOption) (CloudEventsService_ReceiveClient, error)

+ Request func(ctx context.Context, in *CloudEventInput, opts ...grpc.CallOption) (*CloudEvent, error)

+ Send func(ctx context.Context, in *CloudEventInput, opts ...grpc.CallOption) (*empty.Empty, error)

+ func NewCloudEventsServiceClient(cc grpc.ClientConnInterface) CloudEventsServiceClient

+ type CloudEventsServiceServer interface

+ Receive func(*ReceiveRequest, CloudEventsService_ReceiveServer) error

+ Request func(context.Context, *CloudEventInput) (*CloudEvent, error)

+ Send func(context.Context, *CloudEventInput) (*empty.Empty, error)

+ type CloudEventsService_ReceiveClient interface

+ Recv func() (*CloudEvent, error)

+ type CloudEventsService_ReceiveServer interface

+ Send func(*CloudEvent) error

+ type ReceiveRequest struct

+ Subject string

+ Type string

+ func (*ReceiveRequest) Descriptor() ([]byte, []int)

+ func (*ReceiveRequest) ProtoMessage()

+ func (this *ReceiveRequest) Validate() error

+ func (x *ReceiveRequest) GetSubject() string

+ func (x *ReceiveRequest) GetType() string

+ func (x *ReceiveRequest) ProtoReflect() protoreflect.Message

+ func (x *ReceiveRequest) Reset()

+ func (x *ReceiveRequest) String() string

+ type UnimplementedCloudEventsServiceServer struct

+ func (*UnimplementedCloudEventsServiceServer) Receive(*ReceiveRequest, CloudEventsService_ReceiveServer) error

+ func (*UnimplementedCloudEventsServiceServer) Request(context.Context, *CloudEventInput) (*CloudEvent, error)

+ func (*UnimplementedCloudEventsServiceServer) Send(context.Context, *CloudEventInput) (*empty.Empty, error)