events

package

Go to main page

Versions in this module

v3

v3.9.0

Sep 13, 2022

v3.8.9

Sep 9, 2022

v3.8.8

Aug 31, 2022

v3.8.7

Jun 13, 2022

v3.8.6

Apr 1, 2022

v3.8.5

Feb 18, 2022

v3.8.4

Feb 10, 2022

v3.8.3

Jan 13, 2022

Changes in this version

+ var File_proto_events_events_proto protoreflect.FileDescriptor

type AckRequest

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

type ConsumeRequest

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

type Event

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

type PublishRequest

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

type PublishResponse

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

type ReadRequest

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

type ReadResponse

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

+ type UnimplementedStoreServer struct

+ func (*UnimplementedStoreServer) Read(context.Context, *ReadRequest) (*ReadResponse, error)

+ func (*UnimplementedStoreServer) Write(context.Context, *WriteRequest) (*WriteResponse, error)

+ type UnimplementedStreamServer struct

+ func (*UnimplementedStreamServer) Consume(*ConsumeRequest, Stream_ConsumeServer) error

+ func (*UnimplementedStreamServer) Publish(context.Context, *PublishRequest) (*PublishResponse, error)

type WriteRequest

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

type WriteResponse

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

v3.8.2

Dec 15, 2021

v3.8.1

Dec 15, 2021

Changes in this version

+ func NewStoreEndpoints() []*api.Endpoint

+ func NewStreamEndpoints() []*api.Endpoint

+ func RegisterStoreHandler(s server.Server, hdlr StoreHandler, opts ...server.HandlerOption) error

+ func RegisterStoreServer(s *grpc.Server, srv StoreServer)

+ func RegisterStreamHandler(s server.Server, hdlr StreamHandler, opts ...server.HandlerOption) error

+ func RegisterStreamServer(s *grpc.Server, srv StreamServer)

+ type AckRequest struct

+ Id string

+ Success bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*AckRequest) ProtoMessage()

+ func (m *AckRequest) GetId() string

+ func (m *AckRequest) GetSuccess() bool

+ func (m *AckRequest) Reset()

+ func (m *AckRequest) String() string

+ func (m *AckRequest) XXX_DiscardUnknown()

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

+ func (m *AckRequest) XXX_Merge(src proto.Message)

+ func (m *AckRequest) XXX_Size() int

+ func (m *AckRequest) XXX_Unmarshal(b []byte) error

+ type ConsumeRequest struct

+ AckWait int64

+ AutoAck bool

+ Group string

+ Offset int64

+ RetryLimit int64

+ Topic string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ConsumeRequest) ProtoMessage()

+ func (m *ConsumeRequest) GetAckWait() int64

+ func (m *ConsumeRequest) GetAutoAck() bool

+ func (m *ConsumeRequest) GetGroup() string

+ func (m *ConsumeRequest) GetOffset() int64

+ func (m *ConsumeRequest) GetRetryLimit() int64

+ func (m *ConsumeRequest) GetTopic() string

+ func (m *ConsumeRequest) Reset()

+ func (m *ConsumeRequest) String() string

+ func (m *ConsumeRequest) XXX_DiscardUnknown()

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

+ func (m *ConsumeRequest) XXX_Merge(src proto.Message)

+ func (m *ConsumeRequest) XXX_Size() int

+ func (m *ConsumeRequest) XXX_Unmarshal(b []byte) error

+ type Event struct

+ Id string

+ Metadata map[string]string

+ Payload []byte

+ Timestamp int64

+ Topic string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Event) ProtoMessage()

+ func (m *Event) GetId() string

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

+ func (m *Event) GetPayload() []byte

+ func (m *Event) GetTimestamp() int64

+ func (m *Event) GetTopic() string

+ func (m *Event) Reset()

+ func (m *Event) String() string

+ func (m *Event) XXX_DiscardUnknown()

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

+ func (m *Event) XXX_Merge(src proto.Message)

+ func (m *Event) XXX_Size() int

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

+ type PublishRequest struct

+ Metadata map[string]string

+ Payload []byte

+ Timestamp int64

+ Topic string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*PublishRequest) ProtoMessage()

+ func (m *PublishRequest) GetMetadata() map[string]string

+ func (m *PublishRequest) GetPayload() []byte

+ func (m *PublishRequest) GetTimestamp() int64

+ func (m *PublishRequest) GetTopic() string

+ func (m *PublishRequest) Reset()

+ func (m *PublishRequest) String() string

+ func (m *PublishRequest) XXX_DiscardUnknown()

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

+ func (m *PublishRequest) XXX_Merge(src proto.Message)

+ func (m *PublishRequest) XXX_Size() int

+ func (m *PublishRequest) XXX_Unmarshal(b []byte) error

+ type PublishResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*PublishResponse) ProtoMessage()

+ func (m *PublishResponse) Reset()

+ func (m *PublishResponse) String() string

+ func (m *PublishResponse) XXX_DiscardUnknown()

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

+ func (m *PublishResponse) XXX_Merge(src proto.Message)

+ func (m *PublishResponse) XXX_Size() int

+ func (m *PublishResponse) XXX_Unmarshal(b []byte) error

+ type ReadRequest struct

+ Limit uint64

+ Offset uint64

+ Topic string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ReadRequest) ProtoMessage()

+ func (m *ReadRequest) GetLimit() uint64

+ func (m *ReadRequest) GetOffset() uint64

+ func (m *ReadRequest) GetTopic() string

+ func (m *ReadRequest) Reset()

+ func (m *ReadRequest) String() string

+ func (m *ReadRequest) XXX_DiscardUnknown()

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

+ func (m *ReadRequest) XXX_Merge(src proto.Message)

+ func (m *ReadRequest) XXX_Size() int

+ func (m *ReadRequest) XXX_Unmarshal(b []byte) error

+ type ReadResponse struct

+ Events []*Event

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ReadResponse) ProtoMessage()

+ func (m *ReadResponse) GetEvents() []*Event

+ func (m *ReadResponse) Reset()

+ func (m *ReadResponse) String() string

+ func (m *ReadResponse) XXX_DiscardUnknown()

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

+ func (m *ReadResponse) XXX_Merge(src proto.Message)

+ func (m *ReadResponse) XXX_Size() int

+ func (m *ReadResponse) XXX_Unmarshal(b []byte) error

+ type StoreClient interface

+ Read func(ctx context.Context, in *ReadRequest, opts ...grpc.CallOption) (*ReadResponse, error)

+ Write func(ctx context.Context, in *WriteRequest, opts ...grpc.CallOption) (*WriteResponse, error)

+ func NewStoreClient(cc *grpc.ClientConn) StoreClient

+ type StoreHandler interface

+ Read func(context.Context, *ReadRequest, *ReadResponse) error

+ Write func(context.Context, *WriteRequest, *WriteResponse) error

+ type StoreServer interface

+ Read func(context.Context, *ReadRequest) (*ReadResponse, error)

+ Write func(context.Context, *WriteRequest) (*WriteResponse, error)

+ type StoreService interface

+ Read func(ctx context.Context, in *ReadRequest, opts ...client.CallOption) (*ReadResponse, error)

+ Write func(ctx context.Context, in *WriteRequest, opts ...client.CallOption) (*WriteResponse, error)

+ func NewStoreService(name string, c client.Client) StoreService

+ type StreamClient interface

+ Consume func(ctx context.Context, in *ConsumeRequest, opts ...grpc.CallOption) (Stream_ConsumeClient, error)

+ Publish func(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*PublishResponse, error)

+ func NewStreamClient(cc *grpc.ClientConn) StreamClient

+ type StreamHandler interface

+ Consume func(context.Context, *ConsumeRequest, Stream_ConsumeStream) error

+ Publish func(context.Context, *PublishRequest, *PublishResponse) error

+ type StreamServer interface

+ Consume func(*ConsumeRequest, Stream_ConsumeServer) error

+ Publish func(context.Context, *PublishRequest) (*PublishResponse, error)

+ type StreamService interface

+ Consume func(ctx context.Context, in *ConsumeRequest, opts ...client.CallOption) (Stream_ConsumeService, error)

+ Publish func(ctx context.Context, in *PublishRequest, opts ...client.CallOption) (*PublishResponse, error)

+ func NewStreamService(name string, c client.Client) StreamService

+ type Stream_ConsumeClient interface

+ Recv func() (*Event, error)

+ type Stream_ConsumeServer interface

+ Send func(*Event) error

+ type Stream_ConsumeService interface

+ Close func() error

+ Context func() context.Context

+ Recv func() (*Event, error)

+ RecvMsg func(interface{}) error

+ SendMsg func(interface{}) error

+ type Stream_ConsumeStream interface

+ Close func() error

+ Context func() context.Context

+ RecvMsg func(interface{}) error

+ Send func(*Event) error

+ SendMsg func(interface{}) error

+ type WriteRequest struct

+ Event *Event

+ Ttl int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*WriteRequest) ProtoMessage()

+ func (m *WriteRequest) GetEvent() *Event

+ func (m *WriteRequest) GetTtl() int64

+ func (m *WriteRequest) Reset()

+ func (m *WriteRequest) String() string

+ func (m *WriteRequest) XXX_DiscardUnknown()

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

+ func (m *WriteRequest) XXX_Merge(src proto.Message)

+ func (m *WriteRequest) XXX_Size() int

+ func (m *WriteRequest) XXX_Unmarshal(b []byte) error

+ type WriteResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*WriteResponse) ProtoMessage()

+ func (m *WriteResponse) Reset()

+ func (m *WriteResponse) String() string

+ func (m *WriteResponse) XXX_DiscardUnknown()

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

+ func (m *WriteResponse) XXX_Merge(src proto.Message)

+ func (m *WriteResponse) XXX_Size() int

+ func (m *WriteResponse) XXX_Unmarshal(b []byte) error

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