evntsrc_storer

package
v0.0.0-...-0172641 Latest Latest
Warning

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

 Go to latest Published: Sep 5, 2020 License: GPL-3.0 Imports: 11 Imported by: 0

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

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) MarshalTo 

func (m *DeleteRequest) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *DeleteResponse) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *ExtendTTLRequest) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *QueryRequest) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *QueryRequest_Ttl) MarshalTo(dAtA []byte) (int, error)

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) MarshalTo 

func (m *QueryTTLExpired) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *StoreRequest) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *StoreResponse) MarshalTo(dAtA []byte) (int, 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
}

Source Files

View all Source files

Directories

Path Synopsis
Package mock_protos is a generated GoMock package.
 Package mock_protos is a generated GoMock package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.