Documentation ¶
Overview ¶
Package evntsrc_storer is a generated protocol buffer package.
It is generated from these files:
storer.proto
It has these top-level messages:
AcknowledgeRequest AcknowledgeResponse ExtendTTLRequest ExtendTTLResponse QueryRequest QueryTTLExpired ReplayEventRequest ReplayEventResponse StoreRequest StoreResponse DeleteRequest DeleteResponse
Index ¶
- Variables
- func RegisterStorerServiceServer(s *grpc.Server, srv StorerServiceServer)
- type AcknowledgeRequest
- func (*AcknowledgeRequest) Descriptor() ([]byte, []int)
- func (m *AcknowledgeRequest) GetEventID() string
- func (m *AcknowledgeRequest) GetStream() int32
- func (m *AcknowledgeRequest) Marshal() (dAtA []byte, err error)
- func (m *AcknowledgeRequest) MarshalTo(dAtA []byte) (int, error)
- func (*AcknowledgeRequest) ProtoMessage()
- func (m *AcknowledgeRequest) Reset()
- func (m *AcknowledgeRequest) Size() (n int)
- func (m *AcknowledgeRequest) String() string
- func (m *AcknowledgeRequest) Unmarshal(dAtA []byte) error
- func (*AcknowledgeRequest) XXX_MessageName() string
- type AcknowledgeResponse
- func (*AcknowledgeResponse) Descriptor() ([]byte, []int)
- func (m *AcknowledgeResponse) GetTime() *time.Time
- func (m *AcknowledgeResponse) Marshal() (dAtA []byte, err error)
- func (m *AcknowledgeResponse) MarshalTo(dAtA []byte) (int, error)
- func (*AcknowledgeResponse) ProtoMessage()
- func (m *AcknowledgeResponse) Reset()
- func (m *AcknowledgeResponse) Size() (n int)
- func (m *AcknowledgeResponse) String() string
- func (m *AcknowledgeResponse) Unmarshal(dAtA []byte) error
- func (*AcknowledgeResponse) XXX_MessageName() string
- type DeleteRequest
- func (*DeleteRequest) Descriptor() ([]byte, []int)
- func (m *DeleteRequest) GetEventID() string
- func (m *DeleteRequest) GetStream() int32
- func (m *DeleteRequest) Marshal() (dAtA []byte, err error)
- func (m *DeleteRequest) MarshalTo(dAtA []byte) (int, error)
- func (*DeleteRequest) ProtoMessage()
- func (m *DeleteRequest) Reset()
- func (m *DeleteRequest) Size() (n int)
- func (m *DeleteRequest) String() string
- func (m *DeleteRequest) Unmarshal(dAtA []byte) error
- func (*DeleteRequest) XXX_MessageName() string
- type DeleteResponse
- func (*DeleteResponse) Descriptor() ([]byte, []int)
- func (m *DeleteResponse) Marshal() (dAtA []byte, err error)
- func (m *DeleteResponse) MarshalTo(dAtA []byte) (int, error)
- func (*DeleteResponse) ProtoMessage()
- func (m *DeleteResponse) Reset()
- func (m *DeleteResponse) Size() (n int)
- func (m *DeleteResponse) String() string
- func (m *DeleteResponse) Unmarshal(dAtA []byte) error
- func (*DeleteResponse) XXX_MessageName() string
- type ExtendTTLRequest
- func (*ExtendTTLRequest) Descriptor() ([]byte, []int)
- func (m *ExtendTTLRequest) GetCurrentTTL() *time.Time
- func (m *ExtendTTLRequest) GetEventID() string
- func (m *ExtendTTLRequest) GetStream() int32
- func (m *ExtendTTLRequest) GetTTLTime() *time.Time
- func (m *ExtendTTLRequest) Marshal() (dAtA []byte, err error)
- func (m *ExtendTTLRequest) MarshalTo(dAtA []byte) (int, error)
- func (*ExtendTTLRequest) ProtoMessage()
- func (m *ExtendTTLRequest) Reset()
- func (m *ExtendTTLRequest) Size() (n int)
- func (m *ExtendTTLRequest) String() string
- func (m *ExtendTTLRequest) Unmarshal(dAtA []byte) error
- func (*ExtendTTLRequest) XXX_MessageName() string
- type ExtendTTLResponse
- func (*ExtendTTLResponse) Descriptor() ([]byte, []int)
- func (m *ExtendTTLResponse) Marshal() (dAtA []byte, err error)
- func (m *ExtendTTLResponse) MarshalTo(dAtA []byte) (int, error)
- func (*ExtendTTLResponse) ProtoMessage()
- func (m *ExtendTTLResponse) Reset()
- func (m *ExtendTTLResponse) Size() (n int)
- func (m *ExtendTTLResponse) String() string
- func (m *ExtendTTLResponse) Unmarshal(dAtA []byte) error
- func (*ExtendTTLResponse) XXX_MessageName() string
- type QueryRequest
- func (*QueryRequest) Descriptor() ([]byte, []int)
- func (m *QueryRequest) GetLimit() int32
- func (m *QueryRequest) GetQuery() isQueryRequest_Query
- func (m *QueryRequest) GetStream() int32
- func (m *QueryRequest) GetTtl() *QueryTTLExpired
- func (m *QueryRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryRequest) MarshalTo(dAtA []byte) (int, error)
- func (*QueryRequest) ProtoMessage()
- func (m *QueryRequest) Reset()
- func (m *QueryRequest) Size() (n int)
- func (m *QueryRequest) String() string
- func (m *QueryRequest) Unmarshal(dAtA []byte) error
- func (*QueryRequest) XXX_MessageName() string
- func (*QueryRequest) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- type QueryRequest_Ttl
- type QueryTTLExpired
- func (*QueryTTLExpired) Descriptor() ([]byte, []int)
- func (m *QueryTTLExpired) GetTime() *time.Time
- func (m *QueryTTLExpired) Marshal() (dAtA []byte, err error)
- func (m *QueryTTLExpired) MarshalTo(dAtA []byte) (int, error)
- func (*QueryTTLExpired) ProtoMessage()
- func (m *QueryTTLExpired) Reset()
- func (m *QueryTTLExpired) Size() (n int)
- func (m *QueryTTLExpired) String() string
- func (m *QueryTTLExpired) Unmarshal(dAtA []byte) error
- func (*QueryTTLExpired) XXX_MessageName() string
- type ReplayEventRequest
- func (*ReplayEventRequest) Descriptor() ([]byte, []int)
- func (m *ReplayEventRequest) GetEventID() string
- func (m *ReplayEventRequest) GetStream() int32
- func (m *ReplayEventRequest) Marshal() (dAtA []byte, err error)
- func (m *ReplayEventRequest) MarshalTo(dAtA []byte) (int, error)
- func (*ReplayEventRequest) ProtoMessage()
- func (m *ReplayEventRequest) Reset()
- func (m *ReplayEventRequest) Size() (n int)
- func (m *ReplayEventRequest) String() string
- func (m *ReplayEventRequest) Unmarshal(dAtA []byte) error
- func (*ReplayEventRequest) XXX_MessageName() string
- type ReplayEventResponse
- func (*ReplayEventResponse) Descriptor() ([]byte, []int)
- func (m *ReplayEventResponse) Marshal() (dAtA []byte, err error)
- func (m *ReplayEventResponse) MarshalTo(dAtA []byte) (int, error)
- func (*ReplayEventResponse) ProtoMessage()
- func (m *ReplayEventResponse) Reset()
- func (m *ReplayEventResponse) Size() (n int)
- func (m *ReplayEventResponse) String() string
- func (m *ReplayEventResponse) Unmarshal(dAtA []byte) error
- func (*ReplayEventResponse) XXX_MessageName() string
- type StoreRequest
- func (*StoreRequest) Descriptor() ([]byte, []int)
- func (m *StoreRequest) GetEvent() *evntsrc_event.Event
- func (m *StoreRequest) Marshal() (dAtA []byte, err error)
- func (m *StoreRequest) MarshalTo(dAtA []byte) (int, error)
- func (*StoreRequest) ProtoMessage()
- func (m *StoreRequest) Reset()
- func (m *StoreRequest) Size() (n int)
- func (m *StoreRequest) String() string
- func (m *StoreRequest) Unmarshal(dAtA []byte) error
- func (*StoreRequest) XXX_MessageName() string
- type StoreResponse
- func (*StoreResponse) Descriptor() ([]byte, []int)
- func (m *StoreResponse) Marshal() (dAtA []byte, err error)
- func (m *StoreResponse) MarshalTo(dAtA []byte) (int, error)
- func (*StoreResponse) ProtoMessage()
- func (m *StoreResponse) Reset()
- func (m *StoreResponse) Size() (n int)
- func (m *StoreResponse) String() string
- func (m *StoreResponse) Unmarshal(dAtA []byte) error
- func (*StoreResponse) XXX_MessageName() string
- type StorerServiceClient
- type StorerServiceServer
- type StorerService_QueryClient
- type StorerService_QueryServer
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthStorer = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowStorer = fmt.Errorf("proto: integer overflow") )
Functions ¶
func RegisterStorerServiceServer ¶
func RegisterStorerServiceServer(s *grpc.Server, srv StorerServiceServer)
Types ¶
type AcknowledgeRequest ¶
type AcknowledgeRequest struct { Stream int32 `protobuf:"varint,1,opt,name=Stream,proto3" json:"Stream,omitempty"` EventID string `protobuf:"bytes,2,opt,name=EventID,proto3" json:"EventID,omitempty"` }
func (*AcknowledgeRequest) Descriptor ¶
func (*AcknowledgeRequest) Descriptor() ([]byte, []int)
func (*AcknowledgeRequest) GetEventID ¶
func (m *AcknowledgeRequest) GetEventID() string
func (*AcknowledgeRequest) GetStream ¶
func (m *AcknowledgeRequest) GetStream() int32
func (*AcknowledgeRequest) Marshal ¶
func (m *AcknowledgeRequest) Marshal() (dAtA []byte, err error)
func (*AcknowledgeRequest) MarshalTo ¶
func (m *AcknowledgeRequest) MarshalTo(dAtA []byte) (int, error)
func (*AcknowledgeRequest) ProtoMessage ¶
func (*AcknowledgeRequest) ProtoMessage()
func (*AcknowledgeRequest) Reset ¶
func (m *AcknowledgeRequest) Reset()
func (*AcknowledgeRequest) Size ¶
func (m *AcknowledgeRequest) Size() (n int)
func (*AcknowledgeRequest) String ¶
func (m *AcknowledgeRequest) String() string
func (*AcknowledgeRequest) Unmarshal ¶
func (m *AcknowledgeRequest) Unmarshal(dAtA []byte) error
func (*AcknowledgeRequest) XXX_MessageName ¶
func (*AcknowledgeRequest) XXX_MessageName() string
type AcknowledgeResponse ¶
type AcknowledgeResponse struct {
Time *time.Time `protobuf:"bytes,1,opt,name=Time,stdtime" json:"Time,omitempty"`
}
func (*AcknowledgeResponse) Descriptor ¶
func (*AcknowledgeResponse) Descriptor() ([]byte, []int)
func (*AcknowledgeResponse) GetTime ¶
func (m *AcknowledgeResponse) GetTime() *time.Time
func (*AcknowledgeResponse) Marshal ¶
func (m *AcknowledgeResponse) Marshal() (dAtA []byte, err error)
func (*AcknowledgeResponse) MarshalTo ¶
func (m *AcknowledgeResponse) MarshalTo(dAtA []byte) (int, error)
func (*AcknowledgeResponse) ProtoMessage ¶
func (*AcknowledgeResponse) ProtoMessage()
func (*AcknowledgeResponse) Reset ¶
func (m *AcknowledgeResponse) Reset()
func (*AcknowledgeResponse) Size ¶
func (m *AcknowledgeResponse) Size() (n int)
func (*AcknowledgeResponse) String ¶
func (m *AcknowledgeResponse) String() string
func (*AcknowledgeResponse) Unmarshal ¶
func (m *AcknowledgeResponse) Unmarshal(dAtA []byte) error
func (*AcknowledgeResponse) XXX_MessageName ¶
func (*AcknowledgeResponse) XXX_MessageName() string
type DeleteRequest ¶
type DeleteRequest struct { Stream int32 `protobuf:"varint,1,opt,name=Stream,proto3" json:"Stream,omitempty"` EventID string `protobuf:"bytes,2,opt,name=EventID,proto3" json:"EventID,omitempty"` }
func (*DeleteRequest) Descriptor ¶
func (*DeleteRequest) Descriptor() ([]byte, []int)
func (*DeleteRequest) GetEventID ¶
func (m *DeleteRequest) GetEventID() string
func (*DeleteRequest) GetStream ¶
func (m *DeleteRequest) GetStream() int32
func (*DeleteRequest) Marshal ¶
func (m *DeleteRequest) Marshal() (dAtA []byte, err error)
func (*DeleteRequest) ProtoMessage ¶
func (*DeleteRequest) ProtoMessage()
func (*DeleteRequest) Reset ¶
func (m *DeleteRequest) Reset()
func (*DeleteRequest) Size ¶
func (m *DeleteRequest) Size() (n int)
func (*DeleteRequest) String ¶
func (m *DeleteRequest) String() string
func (*DeleteRequest) Unmarshal ¶
func (m *DeleteRequest) Unmarshal(dAtA []byte) error
func (*DeleteRequest) XXX_MessageName ¶
func (*DeleteRequest) XXX_MessageName() string
type DeleteResponse ¶
type DeleteResponse struct { }
func (*DeleteResponse) Descriptor ¶
func (*DeleteResponse) Descriptor() ([]byte, []int)
func (*DeleteResponse) Marshal ¶
func (m *DeleteResponse) Marshal() (dAtA []byte, err error)
func (*DeleteResponse) ProtoMessage ¶
func (*DeleteResponse) ProtoMessage()
func (*DeleteResponse) Reset ¶
func (m *DeleteResponse) Reset()
func (*DeleteResponse) Size ¶
func (m *DeleteResponse) Size() (n int)
func (*DeleteResponse) String ¶
func (m *DeleteResponse) String() string
func (*DeleteResponse) Unmarshal ¶
func (m *DeleteResponse) Unmarshal(dAtA []byte) error
func (*DeleteResponse) XXX_MessageName ¶
func (*DeleteResponse) XXX_MessageName() string
type ExtendTTLRequest ¶
type ExtendTTLRequest struct { Stream int32 `protobuf:"varint,1,opt,name=Stream,proto3" json:"Stream,omitempty"` EventID string `protobuf:"bytes,2,opt,name=EventID,proto3" json:"EventID,omitempty"` CurrentTTL *time.Time `protobuf:"bytes,3,opt,name=CurrentTTL,stdtime" json:"CurrentTTL,omitempty"` TTLTime *time.Time `protobuf:"bytes,4,opt,name=TTLTime,stdtime" json:"TTLTime,omitempty"` }
func (*ExtendTTLRequest) Descriptor ¶
func (*ExtendTTLRequest) Descriptor() ([]byte, []int)
func (*ExtendTTLRequest) GetCurrentTTL ¶
func (m *ExtendTTLRequest) GetCurrentTTL() *time.Time
func (*ExtendTTLRequest) GetEventID ¶
func (m *ExtendTTLRequest) GetEventID() string
func (*ExtendTTLRequest) GetStream ¶
func (m *ExtendTTLRequest) GetStream() int32
func (*ExtendTTLRequest) GetTTLTime ¶
func (m *ExtendTTLRequest) GetTTLTime() *time.Time
func (*ExtendTTLRequest) Marshal ¶
func (m *ExtendTTLRequest) Marshal() (dAtA []byte, err error)
func (*ExtendTTLRequest) ProtoMessage ¶
func (*ExtendTTLRequest) ProtoMessage()
func (*ExtendTTLRequest) Reset ¶
func (m *ExtendTTLRequest) Reset()
func (*ExtendTTLRequest) Size ¶
func (m *ExtendTTLRequest) Size() (n int)
func (*ExtendTTLRequest) String ¶
func (m *ExtendTTLRequest) String() string
func (*ExtendTTLRequest) Unmarshal ¶
func (m *ExtendTTLRequest) Unmarshal(dAtA []byte) error
func (*ExtendTTLRequest) XXX_MessageName ¶
func (*ExtendTTLRequest) XXX_MessageName() string
type ExtendTTLResponse ¶
type ExtendTTLResponse struct { }
func (*ExtendTTLResponse) Descriptor ¶
func (*ExtendTTLResponse) Descriptor() ([]byte, []int)
func (*ExtendTTLResponse) Marshal ¶
func (m *ExtendTTLResponse) Marshal() (dAtA []byte, err error)
func (*ExtendTTLResponse) MarshalTo ¶
func (m *ExtendTTLResponse) MarshalTo(dAtA []byte) (int, error)
func (*ExtendTTLResponse) ProtoMessage ¶
func (*ExtendTTLResponse) ProtoMessage()
func (*ExtendTTLResponse) Reset ¶
func (m *ExtendTTLResponse) Reset()
func (*ExtendTTLResponse) Size ¶
func (m *ExtendTTLResponse) Size() (n int)
func (*ExtendTTLResponse) String ¶
func (m *ExtendTTLResponse) String() string
func (*ExtendTTLResponse) Unmarshal ¶
func (m *ExtendTTLResponse) Unmarshal(dAtA []byte) error
func (*ExtendTTLResponse) XXX_MessageName ¶
func (*ExtendTTLResponse) XXX_MessageName() string
type QueryRequest ¶
type QueryRequest struct { Stream int32 `protobuf:"varint,1,opt,name=Stream,proto3" json:"Stream,omitempty"` Limit int32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"` // Types that are valid to be assigned to Query: // *QueryRequest_Ttl Query isQueryRequest_Query `protobuf_oneof:"query"` }
func (*QueryRequest) Descriptor ¶
func (*QueryRequest) Descriptor() ([]byte, []int)
func (*QueryRequest) GetLimit ¶
func (m *QueryRequest) GetLimit() int32
func (*QueryRequest) GetQuery ¶
func (m *QueryRequest) GetQuery() isQueryRequest_Query
func (*QueryRequest) GetStream ¶
func (m *QueryRequest) GetStream() int32
func (*QueryRequest) GetTtl ¶
func (m *QueryRequest) GetTtl() *QueryTTLExpired
func (*QueryRequest) Marshal ¶
func (m *QueryRequest) Marshal() (dAtA []byte, err error)
func (*QueryRequest) ProtoMessage ¶
func (*QueryRequest) ProtoMessage()
func (*QueryRequest) Reset ¶
func (m *QueryRequest) Reset()
func (*QueryRequest) Size ¶
func (m *QueryRequest) Size() (n int)
func (*QueryRequest) String ¶
func (m *QueryRequest) String() string
func (*QueryRequest) Unmarshal ¶
func (m *QueryRequest) Unmarshal(dAtA []byte) error
func (*QueryRequest) XXX_MessageName ¶
func (*QueryRequest) XXX_MessageName() string
func (*QueryRequest) XXX_OneofFuncs ¶
func (*QueryRequest) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
type QueryRequest_Ttl ¶
type QueryRequest_Ttl struct {
Ttl *QueryTTLExpired `protobuf:"bytes,3,opt,name=ttl,oneof"`
}
func (*QueryRequest_Ttl) Size ¶
func (m *QueryRequest_Ttl) Size() (n int)
type QueryTTLExpired ¶
type QueryTTLExpired struct {
Time *time.Time `protobuf:"bytes,1,opt,name=Time,stdtime" json:"Time,omitempty"`
}
func (*QueryTTLExpired) Descriptor ¶
func (*QueryTTLExpired) Descriptor() ([]byte, []int)
func (*QueryTTLExpired) GetTime ¶
func (m *QueryTTLExpired) GetTime() *time.Time
func (*QueryTTLExpired) Marshal ¶
func (m *QueryTTLExpired) Marshal() (dAtA []byte, err error)
func (*QueryTTLExpired) ProtoMessage ¶
func (*QueryTTLExpired) ProtoMessage()
func (*QueryTTLExpired) Reset ¶
func (m *QueryTTLExpired) Reset()
func (*QueryTTLExpired) Size ¶
func (m *QueryTTLExpired) Size() (n int)
func (*QueryTTLExpired) String ¶
func (m *QueryTTLExpired) String() string
func (*QueryTTLExpired) Unmarshal ¶
func (m *QueryTTLExpired) Unmarshal(dAtA []byte) error
func (*QueryTTLExpired) XXX_MessageName ¶
func (*QueryTTLExpired) XXX_MessageName() string
type ReplayEventRequest ¶
type ReplayEventRequest struct { Stream int32 `protobuf:"varint,1,opt,name=Stream,proto3" json:"Stream,omitempty"` EventID string `protobuf:"bytes,2,opt,name=EventID,proto3" json:"EventID,omitempty"` }
func (*ReplayEventRequest) Descriptor ¶
func (*ReplayEventRequest) Descriptor() ([]byte, []int)
func (*ReplayEventRequest) GetEventID ¶
func (m *ReplayEventRequest) GetEventID() string
func (*ReplayEventRequest) GetStream ¶
func (m *ReplayEventRequest) GetStream() int32
func (*ReplayEventRequest) Marshal ¶
func (m *ReplayEventRequest) Marshal() (dAtA []byte, err error)
func (*ReplayEventRequest) MarshalTo ¶
func (m *ReplayEventRequest) MarshalTo(dAtA []byte) (int, error)
func (*ReplayEventRequest) ProtoMessage ¶
func (*ReplayEventRequest) ProtoMessage()
func (*ReplayEventRequest) Reset ¶
func (m *ReplayEventRequest) Reset()
func (*ReplayEventRequest) Size ¶
func (m *ReplayEventRequest) Size() (n int)
func (*ReplayEventRequest) String ¶
func (m *ReplayEventRequest) String() string
func (*ReplayEventRequest) Unmarshal ¶
func (m *ReplayEventRequest) Unmarshal(dAtA []byte) error
func (*ReplayEventRequest) XXX_MessageName ¶
func (*ReplayEventRequest) XXX_MessageName() string
type ReplayEventResponse ¶
type ReplayEventResponse struct { }
func (*ReplayEventResponse) Descriptor ¶
func (*ReplayEventResponse) Descriptor() ([]byte, []int)
func (*ReplayEventResponse) Marshal ¶
func (m *ReplayEventResponse) Marshal() (dAtA []byte, err error)
func (*ReplayEventResponse) MarshalTo ¶
func (m *ReplayEventResponse) MarshalTo(dAtA []byte) (int, error)
func (*ReplayEventResponse) ProtoMessage ¶
func (*ReplayEventResponse) ProtoMessage()
func (*ReplayEventResponse) Reset ¶
func (m *ReplayEventResponse) Reset()
func (*ReplayEventResponse) Size ¶
func (m *ReplayEventResponse) Size() (n int)
func (*ReplayEventResponse) String ¶
func (m *ReplayEventResponse) String() string
func (*ReplayEventResponse) Unmarshal ¶
func (m *ReplayEventResponse) Unmarshal(dAtA []byte) error
func (*ReplayEventResponse) XXX_MessageName ¶
func (*ReplayEventResponse) XXX_MessageName() string
type StoreRequest ¶
type StoreRequest struct {
Event *evntsrc_event.Event `protobuf:"bytes,1,opt,name=Event" json:"Event,omitempty"`
}
func (*StoreRequest) Descriptor ¶
func (*StoreRequest) Descriptor() ([]byte, []int)
func (*StoreRequest) GetEvent ¶
func (m *StoreRequest) GetEvent() *evntsrc_event.Event
func (*StoreRequest) Marshal ¶
func (m *StoreRequest) Marshal() (dAtA []byte, err error)
func (*StoreRequest) ProtoMessage ¶
func (*StoreRequest) ProtoMessage()
func (*StoreRequest) Reset ¶
func (m *StoreRequest) Reset()
func (*StoreRequest) Size ¶
func (m *StoreRequest) Size() (n int)
func (*StoreRequest) String ¶
func (m *StoreRequest) String() string
func (*StoreRequest) Unmarshal ¶
func (m *StoreRequest) Unmarshal(dAtA []byte) error
func (*StoreRequest) XXX_MessageName ¶
func (*StoreRequest) XXX_MessageName() string
type StoreResponse ¶
type StoreResponse struct { }
func (*StoreResponse) Descriptor ¶
func (*StoreResponse) Descriptor() ([]byte, []int)
func (*StoreResponse) Marshal ¶
func (m *StoreResponse) Marshal() (dAtA []byte, err error)
func (*StoreResponse) ProtoMessage ¶
func (*StoreResponse) ProtoMessage()
func (*StoreResponse) Reset ¶
func (m *StoreResponse) Reset()
func (*StoreResponse) Size ¶
func (m *StoreResponse) Size() (n int)
func (*StoreResponse) String ¶
func (m *StoreResponse) String() string
func (*StoreResponse) Unmarshal ¶
func (m *StoreResponse) Unmarshal(dAtA []byte) error
func (*StoreResponse) XXX_MessageName ¶
func (*StoreResponse) XXX_MessageName() string
type StorerServiceClient ¶
type StorerServiceClient interface { Acknowledge(ctx context.Context, in *AcknowledgeRequest, opts ...grpc.CallOption) (*AcknowledgeResponse, error) ExtendTTL(ctx context.Context, in *ExtendTTLRequest, opts ...grpc.CallOption) (*ExtendTTLResponse, error) Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (StorerService_QueryClient, error) ReplayEvent(ctx context.Context, in *ReplayEventRequest, opts ...grpc.CallOption) (*ReplayEventResponse, error) Store(ctx context.Context, in *StoreRequest, opts ...grpc.CallOption) (*StoreResponse, error) Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error) }
func NewStorerServiceClient ¶
func NewStorerServiceClient(cc *grpc.ClientConn) StorerServiceClient
type StorerServiceServer ¶
type StorerServiceServer interface { Acknowledge(context.Context, *AcknowledgeRequest) (*AcknowledgeResponse, error) ExtendTTL(context.Context, *ExtendTTLRequest) (*ExtendTTLResponse, error) Query(*QueryRequest, StorerService_QueryServer) error ReplayEvent(context.Context, *ReplayEventRequest) (*ReplayEventResponse, error) Store(context.Context, *StoreRequest) (*StoreResponse, error) Delete(context.Context, *DeleteRequest) (*DeleteResponse, error) }
type StorerService_QueryClient ¶
type StorerService_QueryClient interface { Recv() (*evntsrc_event.Event, error) grpc.ClientStream }
type StorerService_QueryServer ¶
type StorerService_QueryServer interface { Send(*evntsrc_event.Event) error grpc.ServerStream }
Directories ¶
Path | Synopsis |
---|---|
Package mock_protos is a generated GoMock package.
|
Package mock_protos is a generated GoMock package. |
Click to show internal directories.
Click to hide internal directories.