sgproto

package
v0.1.1 Latest Latest
Warning

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

 Go to latest Published: Oct 29, 2017 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Overview 

Package sgproto is a generated protocol buffer package.

It is generated from these files:
	sandglass.proto

It has these top-level messages:
	Message
	DUIDReply
	CreateTopicParams
	GetTopicParams
	GetTopicReply
	TopicReply
	StoreLocallyReply
	FetchFromRequest
	FetchRangeRequest
	GetRequest
	ConsumeFromGroupRequest
	OffsetChangeRequest
	MultiOffsetChangeRequest
	OffsetChangeReply
	LastOffsetReply
	LastOffsetRequest
	FetchFromSyncRequest
	HasResponse
	SyncRequest
	SyncResponse

Package sgproto is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthSandglass = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSandglass   = fmt.Errorf("proto: integer overflow")
)
View Source 
var ConsistencyLevel_name = map[int32]string{
	0:  "ONE",
	10: "QUORUM",
	20: "ALL",
}
View Source 
var ConsistencyLevel_value = map[string]int32{
	"ONE":    0,
	"QUORUM": 10,
	"ALL":    20,
}
View Source 
var LastOffsetRequest_Kind_name = map[int32]string{
	0:  "Unknown",
	10: "Consumed",
	20: "NotAcknowledged",
	30: "Acknowledged",
	40: "Commited",
}
View Source 
var LastOffsetRequest_Kind_value = map[string]int32{
	"Unknown":         0,
	"Consumed":        10,
	"NotAcknowledged": 20,
	"Acknowledged":    30,
	"Commited":        40,
}
View Source 
var StorageDriver_name = map[int32]string{
	0: "RocksDB",
	1: "Badger",
}
View Source 
var StorageDriver_value = map[string]int32{
	"RocksDB": 0,
	"Badger":  1,
}
View Source 
var TopicKind_name = map[int32]string{
	0: "TimerKind",
	1: "CompactedKind",
}
View Source 
var TopicKind_value = map[string]int32{
	"TimerKind":     0,
	"CompactedKind": 1,
}

Functions

func RegisterBrokerServiceHandler 

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

RegisterBrokerServiceHandler registers the http handlers for service BrokerService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterBrokerServiceHandlerFromEndpoint 

func RegisterBrokerServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterBrokerServiceHandlerFromEndpoint is same as RegisterBrokerServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterBrokerServiceServer 

func RegisterBrokerServiceServer(s *grpc.Server, srv BrokerServiceServer)

func RegisterInternalServiceServer 

func RegisterInternalServiceServer(s *grpc.Server, srv InternalServiceServer)

Types

type BrokerServiceClient 

type BrokerServiceClient interface {
	CreateTopic(ctx context.Context, in *CreateTopicParams, opts ...grpc.CallOption) (*TopicReply, error)
	PublishMessagesStream(ctx context.Context, opts ...grpc.CallOption) (BrokerService_PublishMessagesStreamClient, error)
	GetTopic(ctx context.Context, in *GetTopicParams, opts ...grpc.CallOption) (*GetTopicReply, error)
	Publish(ctx context.Context, in *Message, opts ...grpc.CallOption) (*DUIDReply, error)
	FetchFrom(ctx context.Context, in *FetchFromRequest, opts ...grpc.CallOption) (BrokerService_FetchFromClient, error)
	FetchRange(ctx context.Context, in *FetchRangeRequest, opts ...grpc.CallOption) (BrokerService_FetchRangeClient, error)
	StoreMessagesStream(ctx context.Context, opts ...grpc.CallOption) (BrokerService_StoreMessagesStreamClient, error)
	ConsumeFromGroup(ctx context.Context, in *ConsumeFromGroupRequest, opts ...grpc.CallOption) (BrokerService_ConsumeFromGroupClient, error)
	Acknowledge(ctx context.Context, in *OffsetChangeRequest, opts ...grpc.CallOption) (*OffsetChangeReply, error)
	AcknowledgeMessages(ctx context.Context, in *MultiOffsetChangeRequest, opts ...grpc.CallOption) (*OffsetChangeReply, error)
	Commit(ctx context.Context, in *OffsetChangeRequest, opts ...grpc.CallOption) (*OffsetChangeReply, error)
}

func NewBrokerServiceClient 

func NewBrokerServiceClient(cc *grpc.ClientConn) BrokerServiceClient

type BrokerServiceServer 

type BrokerServiceServer interface {
	CreateTopic(context.Context, *CreateTopicParams) (*TopicReply, error)
	PublishMessagesStream(BrokerService_PublishMessagesStreamServer) error
	GetTopic(context.Context, *GetTopicParams) (*GetTopicReply, error)
	Publish(context.Context, *Message) (*DUIDReply, error)
	FetchFrom(*FetchFromRequest, BrokerService_FetchFromServer) error
	FetchRange(*FetchRangeRequest, BrokerService_FetchRangeServer) error
	StoreMessagesStream(BrokerService_StoreMessagesStreamServer) error
	ConsumeFromGroup(*ConsumeFromGroupRequest, BrokerService_ConsumeFromGroupServer) error
	Acknowledge(context.Context, *OffsetChangeRequest) (*OffsetChangeReply, error)
	AcknowledgeMessages(context.Context, *MultiOffsetChangeRequest) (*OffsetChangeReply, error)
	Commit(context.Context, *OffsetChangeRequest) (*OffsetChangeReply, error)
}

type BrokerService_ConsumeFromGroupClient 

type BrokerService_ConsumeFromGroupClient interface {
	Recv() (*Message, error)
	grpc.ClientStream
}

type BrokerService_ConsumeFromGroupServer 

type BrokerService_ConsumeFromGroupServer interface {
	Send(*Message) error
	grpc.ServerStream
}

type BrokerService_FetchFromClient 

type BrokerService_FetchFromClient interface {
	Recv() (*Message, error)
	grpc.ClientStream
}

type BrokerService_FetchFromServer 

type BrokerService_FetchFromServer interface {
	Send(*Message) error
	grpc.ServerStream
}

type BrokerService_FetchRangeClient 

type BrokerService_FetchRangeClient interface {
	Recv() (*Message, error)
	grpc.ClientStream
}

type BrokerService_FetchRangeServer 

type BrokerService_FetchRangeServer interface {
	Send(*Message) error
	grpc.ServerStream
}

type BrokerService_PublishMessagesStreamClient 

type BrokerService_PublishMessagesStreamClient interface {
	Send(*Message) error
	CloseAndRecv() (*StoreLocallyReply, error)
	grpc.ClientStream
}

type BrokerService_PublishMessagesStreamServer 

type BrokerService_PublishMessagesStreamServer interface {
	SendAndClose(*StoreLocallyReply) error
	Recv() (*Message, error)
	grpc.ServerStream
}

type BrokerService_StoreMessagesStreamClient 

type BrokerService_StoreMessagesStreamClient interface {
	Send(*Message) error
	CloseAndRecv() (*StoreLocallyReply, error)
	grpc.ClientStream
}

type BrokerService_StoreMessagesStreamServer 

type BrokerService_StoreMessagesStreamServer interface {
	SendAndClose(*StoreLocallyReply) error
	Recv() (*Message, error)
	grpc.ServerStream
}

type ConsistencyLevel 

type ConsistencyLevel int32
const (
	ConsistencyLevel_ONE    ConsistencyLevel = 0
	ConsistencyLevel_QUORUM ConsistencyLevel = 10
	ConsistencyLevel_ALL    ConsistencyLevel = 20
)

func (ConsistencyLevel) EnumDescriptor 

func (ConsistencyLevel) EnumDescriptor() ([]byte, []int)

func (ConsistencyLevel) String 

func (x ConsistencyLevel) String() string

type ConsumeFromGroupRequest 

type ConsumeFromGroupRequest struct {
	Topic             string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Partition         string `protobuf:"bytes,2,opt,name=partition,proto3" json:"partition,omitempty"`
	ConsumerGroupName string `protobuf:"bytes,3,opt,name=consumerGroupName,proto3" json:"consumerGroupName,omitempty"`
	ConsumerName      string `protobuf:"bytes,4,opt,name=consumerName,proto3" json:"consumerName,omitempty"`
}

func (*ConsumeFromGroupRequest) Descriptor 

func (*ConsumeFromGroupRequest) Descriptor() ([]byte, []int)

func (*ConsumeFromGroupRequest) Equal 

func (this *ConsumeFromGroupRequest) Equal(that interface{}) bool

func (*ConsumeFromGroupRequest) GetConsumerGroupName 

func (m *ConsumeFromGroupRequest) GetConsumerGroupName() string

func (*ConsumeFromGroupRequest) GetConsumerName 

func (m *ConsumeFromGroupRequest) GetConsumerName() string

func (*ConsumeFromGroupRequest) GetPartition 

func (m *ConsumeFromGroupRequest) GetPartition() string

func (*ConsumeFromGroupRequest) GetTopic 

func (m *ConsumeFromGroupRequest) GetTopic() string

func (*ConsumeFromGroupRequest) Marshal 

func (m *ConsumeFromGroupRequest) Marshal() (dAtA []byte, err error)

func (*ConsumeFromGroupRequest) MarshalTo 

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

func (*ConsumeFromGroupRequest) ProtoMessage 

func (*ConsumeFromGroupRequest) ProtoMessage()

func (*ConsumeFromGroupRequest) Reset 

func (m *ConsumeFromGroupRequest) Reset()

func (*ConsumeFromGroupRequest) Size 

func (m *ConsumeFromGroupRequest) Size() (n int)

func (*ConsumeFromGroupRequest) String 

func (this *ConsumeFromGroupRequest) String() string

func (*ConsumeFromGroupRequest) Unmarshal 

func (m *ConsumeFromGroupRequest) Unmarshal(dAtA []byte) error

type CreateTopicParams 

type CreateTopicParams struct {
	Name              string        `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Kind              TopicKind     `protobuf:"varint,2,opt,name=kind,proto3,enum=sandglass.TopicKind" json:"kind,omitempty"`
	ReplicationFactor int32         `protobuf:"varint,3,opt,name=replicationFactor,proto3" json:"replicationFactor,omitempty"`
	NumPartitions     int32         `protobuf:"varint,4,opt,name=numPartitions,proto3" json:"numPartitions,omitempty"`
	StorageDriver     StorageDriver `protobuf:"varint,5,opt,name=storageDriver,proto3,enum=sandglass.StorageDriver" json:"storageDriver,omitempty"`
}

func (*CreateTopicParams) Descriptor 

func (*CreateTopicParams) Descriptor() ([]byte, []int)

func (*CreateTopicParams) Equal 

func (this *CreateTopicParams) Equal(that interface{}) bool

func (*CreateTopicParams) GetKind 

func (m *CreateTopicParams) GetKind() TopicKind

func (*CreateTopicParams) GetName 

func (m *CreateTopicParams) GetName() string

func (*CreateTopicParams) GetNumPartitions 

func (m *CreateTopicParams) GetNumPartitions() int32

func (*CreateTopicParams) GetReplicationFactor 

func (m *CreateTopicParams) GetReplicationFactor() int32

func (*CreateTopicParams) GetStorageDriver 

func (m *CreateTopicParams) GetStorageDriver() StorageDriver

func (*CreateTopicParams) Marshal 

func (m *CreateTopicParams) Marshal() (dAtA []byte, err error)

func (*CreateTopicParams) MarshalTo 

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

func (*CreateTopicParams) ProtoMessage 

func (*CreateTopicParams) ProtoMessage()

func (*CreateTopicParams) Reset 

func (m *CreateTopicParams) Reset()

func (*CreateTopicParams) Size 

func (m *CreateTopicParams) Size() (n int)

func (*CreateTopicParams) String 

func (this *CreateTopicParams) String() string

func (*CreateTopicParams) Unmarshal 

func (m *CreateTopicParams) Unmarshal(dAtA []byte) error

type DUIDReply 

type DUIDReply struct {
	Id github_com_celrenheit_sandflake.ID `protobuf:"bytes,1,opt,name=id,proto3,customtype=github.com/celrenheit/sandflake.ID" json:"id"`
}

func (*DUIDReply) Descriptor 

func (*DUIDReply) Descriptor() ([]byte, []int)

func (*DUIDReply) Equal 

func (this *DUIDReply) Equal(that interface{}) bool

func (*DUIDReply) Marshal 

func (m *DUIDReply) Marshal() (dAtA []byte, err error)

func (*DUIDReply) MarshalTo 

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

func (*DUIDReply) ProtoMessage 

func (*DUIDReply) ProtoMessage()

func (*DUIDReply) Reset 

func (m *DUIDReply) Reset()

func (*DUIDReply) Size 

func (m *DUIDReply) Size() (n int)

func (*DUIDReply) String 

func (this *DUIDReply) String() string

func (*DUIDReply) Unmarshal 

func (m *DUIDReply) Unmarshal(dAtA []byte) error

type FetchFromRequest 

type FetchFromRequest struct {
	Topic     string                             `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Partition string                             `protobuf:"bytes,2,opt,name=partition,proto3" json:"partition,omitempty"`
	From      github_com_celrenheit_sandflake.ID `protobuf:"bytes,3,opt,name=from,proto3,customtype=github.com/celrenheit/sandflake.ID" json:"from"`
}

func (*FetchFromRequest) Descriptor 

func (*FetchFromRequest) Descriptor() ([]byte, []int)

func (*FetchFromRequest) Equal 

func (this *FetchFromRequest) Equal(that interface{}) bool

func (*FetchFromRequest) GetPartition 

func (m *FetchFromRequest) GetPartition() string

func (*FetchFromRequest) GetTopic 

func (m *FetchFromRequest) GetTopic() string

func (*FetchFromRequest) Marshal 

func (m *FetchFromRequest) Marshal() (dAtA []byte, err error)

func (*FetchFromRequest) MarshalTo 

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

func (*FetchFromRequest) ProtoMessage 

func (*FetchFromRequest) ProtoMessage()

func (*FetchFromRequest) Reset 

func (m *FetchFromRequest) Reset()

func (*FetchFromRequest) Size 

func (m *FetchFromRequest) Size() (n int)

func (*FetchFromRequest) String 

func (this *FetchFromRequest) String() string

func (*FetchFromRequest) Unmarshal 

func (m *FetchFromRequest) Unmarshal(dAtA []byte) error

type FetchFromSyncRequest 

type FetchFromSyncRequest struct {
	Topic     string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Partition string `protobuf:"bytes,2,opt,name=partition,proto3" json:"partition,omitempty"`
	From      []byte `protobuf:"bytes,3,opt,name=from,proto3" json:"from,omitempty"`
}

func (*FetchFromSyncRequest) Descriptor 

func (*FetchFromSyncRequest) Descriptor() ([]byte, []int)

func (*FetchFromSyncRequest) Equal 

func (this *FetchFromSyncRequest) Equal(that interface{}) bool

func (*FetchFromSyncRequest) GetFrom 

func (m *FetchFromSyncRequest) GetFrom() []byte

func (*FetchFromSyncRequest) GetPartition 

func (m *FetchFromSyncRequest) GetPartition() string

func (*FetchFromSyncRequest) GetTopic 

func (m *FetchFromSyncRequest) GetTopic() string

func (*FetchFromSyncRequest) Marshal 

func (m *FetchFromSyncRequest) Marshal() (dAtA []byte, err error)

func (*FetchFromSyncRequest) MarshalTo 

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

func (*FetchFromSyncRequest) ProtoMessage 

func (*FetchFromSyncRequest) ProtoMessage()

func (*FetchFromSyncRequest) Reset 

func (m *FetchFromSyncRequest) Reset()

func (*FetchFromSyncRequest) Size 

func (m *FetchFromSyncRequest) Size() (n int)

func (*FetchFromSyncRequest) String 

func (this *FetchFromSyncRequest) String() string

func (*FetchFromSyncRequest) Unmarshal 

func (m *FetchFromSyncRequest) Unmarshal(dAtA []byte) error

type FetchRangeRequest 

type FetchRangeRequest struct {
	Topic     string                             `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Partition string                             `protobuf:"bytes,2,opt,name=partition,proto3" json:"partition,omitempty"`
	From      github_com_celrenheit_sandflake.ID `protobuf:"bytes,3,opt,name=from,proto3,customtype=github.com/celrenheit/sandflake.ID" json:"from"`
	To        github_com_celrenheit_sandflake.ID `protobuf:"bytes,4,opt,name=to,proto3,customtype=github.com/celrenheit/sandflake.ID" json:"to"`
}

func (*FetchRangeRequest) Descriptor 

func (*FetchRangeRequest) Descriptor() ([]byte, []int)

func (*FetchRangeRequest) Equal 

func (this *FetchRangeRequest) Equal(that interface{}) bool

func (*FetchRangeRequest) GetPartition 

func (m *FetchRangeRequest) GetPartition() string

func (*FetchRangeRequest) GetTopic 

func (m *FetchRangeRequest) GetTopic() string

func (*FetchRangeRequest) Marshal 

func (m *FetchRangeRequest) Marshal() (dAtA []byte, err error)

func (*FetchRangeRequest) MarshalTo 

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

func (*FetchRangeRequest) ProtoMessage 

func (*FetchRangeRequest) ProtoMessage()

func (*FetchRangeRequest) Reset 

func (m *FetchRangeRequest) Reset()

func (*FetchRangeRequest) Size 

func (m *FetchRangeRequest) Size() (n int)

func (*FetchRangeRequest) String 

func (this *FetchRangeRequest) String() string

func (*FetchRangeRequest) Unmarshal 

func (m *FetchRangeRequest) Unmarshal(dAtA []byte) error

type GetRequest 

type GetRequest struct {
	Topic     string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Partition string `protobuf:"bytes,2,opt,name=partition,proto3" json:"partition,omitempty"`
	Key       []byte `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
}

func (*GetRequest) Descriptor 

func (*GetRequest) Descriptor() ([]byte, []int)

func (*GetRequest) Equal 

func (this *GetRequest) Equal(that interface{}) bool

func (*GetRequest) GetKey 

func (m *GetRequest) GetKey() []byte

func (*GetRequest) GetPartition 

func (m *GetRequest) GetPartition() string

func (*GetRequest) GetTopic 

func (m *GetRequest) GetTopic() string

func (*GetRequest) Marshal 

func (m *GetRequest) Marshal() (dAtA []byte, err error)

func (*GetRequest) MarshalTo 

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

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) Reset 

func (m *GetRequest) Reset()

func (*GetRequest) Size 

func (m *GetRequest) Size() (n int)

func (*GetRequest) String 

func (this *GetRequest) String() string

func (*GetRequest) Unmarshal 

func (m *GetRequest) Unmarshal(dAtA []byte) error

type GetTopicParams 

type GetTopicParams struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
}

func (*GetTopicParams) Descriptor 

func (*GetTopicParams) Descriptor() ([]byte, []int)

func (*GetTopicParams) Equal 

func (this *GetTopicParams) Equal(that interface{}) bool

func (*GetTopicParams) GetName 

func (m *GetTopicParams) GetName() string

func (*GetTopicParams) Marshal 

func (m *GetTopicParams) Marshal() (dAtA []byte, err error)

func (*GetTopicParams) MarshalTo 

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

func (*GetTopicParams) ProtoMessage 

func (*GetTopicParams) ProtoMessage()

func (*GetTopicParams) Reset 

func (m *GetTopicParams) Reset()

func (*GetTopicParams) Size 

func (m *GetTopicParams) Size() (n int)

func (*GetTopicParams) String 

func (this *GetTopicParams) String() string

func (*GetTopicParams) Unmarshal 

func (m *GetTopicParams) Unmarshal(dAtA []byte) error

type GetTopicReply 

type GetTopicReply struct {
	Name       string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Partitions []string `protobuf:"bytes,2,rep,name=partitions" json:"partitions,omitempty"`
}

func (*GetTopicReply) Descriptor 

func (*GetTopicReply) Descriptor() ([]byte, []int)

func (*GetTopicReply) Equal 

func (this *GetTopicReply) Equal(that interface{}) bool

func (*GetTopicReply) GetName 

func (m *GetTopicReply) GetName() string

func (*GetTopicReply) GetPartitions 

func (m *GetTopicReply) GetPartitions() []string

func (*GetTopicReply) Marshal 

func (m *GetTopicReply) Marshal() (dAtA []byte, err error)

func (*GetTopicReply) MarshalTo 

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

func (*GetTopicReply) ProtoMessage 

func (*GetTopicReply) ProtoMessage()

func (*GetTopicReply) Reset 

func (m *GetTopicReply) Reset()

func (*GetTopicReply) Size 

func (m *GetTopicReply) Size() (n int)

func (*GetTopicReply) String 

func (this *GetTopicReply) String() string

func (*GetTopicReply) Unmarshal 

func (m *GetTopicReply) Unmarshal(dAtA []byte) error

type HasResponse 

type HasResponse struct {
	Exists bool `protobuf:"varint,1,opt,name=exists,proto3" json:"exists,omitempty"`
}

func (*HasResponse) Descriptor 

func (*HasResponse) Descriptor() ([]byte, []int)

func (*HasResponse) Equal 

func (this *HasResponse) Equal(that interface{}) bool

func (*HasResponse) GetExists 

func (m *HasResponse) GetExists() bool

func (*HasResponse) Marshal 

func (m *HasResponse) Marshal() (dAtA []byte, err error)

func (*HasResponse) MarshalTo 

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

func (*HasResponse) ProtoMessage 

func (*HasResponse) ProtoMessage()

func (*HasResponse) Reset 

func (m *HasResponse) Reset()

func (*HasResponse) Size 

func (m *HasResponse) Size() (n int)

func (*HasResponse) String 

func (this *HasResponse) String() string

func (*HasResponse) Unmarshal 

func (m *HasResponse) Unmarshal(dAtA []byte) error

type InternalServiceClient 

type InternalServiceClient interface {
	StoreMessageLocally(ctx context.Context, in *Message, opts ...grpc.CallOption) (*StoreLocallyReply, error)
	GetByKey(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*Message, error)
	HasKey(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*HasResponse, error)
	FetchFromSync(ctx context.Context, in *FetchFromSyncRequest, opts ...grpc.CallOption) (InternalService_FetchFromSyncClient, error)
	LastOffset(ctx context.Context, in *LastOffsetRequest, opts ...grpc.CallOption) (*LastOffsetReply, error)
}

func NewInternalServiceClient 

func NewInternalServiceClient(cc *grpc.ClientConn) InternalServiceClient

type InternalServiceServer 

type InternalServiceServer interface {
	StoreMessageLocally(context.Context, *Message) (*StoreLocallyReply, error)
	GetByKey(context.Context, *GetRequest) (*Message, error)
	HasKey(context.Context, *GetRequest) (*HasResponse, error)
	FetchFromSync(*FetchFromSyncRequest, InternalService_FetchFromSyncServer) error
	LastOffset(context.Context, *LastOffsetRequest) (*LastOffsetReply, error)
}

type InternalService_FetchFromSyncClient 

type InternalService_FetchFromSyncClient interface {
	Recv() (*Message, error)
	grpc.ClientStream
}

type InternalService_FetchFromSyncServer 

type InternalService_FetchFromSyncServer interface {
	Send(*Message) error
	grpc.ServerStream
}

type LastOffsetReply 

type LastOffsetReply struct {
	Offset github_com_celrenheit_sandflake.ID `protobuf:"bytes,1,opt,name=offset,proto3,customtype=github.com/celrenheit/sandflake.ID" json:"offset"`
}

func (*LastOffsetReply) Descriptor 

func (*LastOffsetReply) Descriptor() ([]byte, []int)

func (*LastOffsetReply) Equal 

func (this *LastOffsetReply) Equal(that interface{}) bool

func (*LastOffsetReply) Marshal 

func (m *LastOffsetReply) Marshal() (dAtA []byte, err error)

func (*LastOffsetReply) MarshalTo 

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

func (*LastOffsetReply) ProtoMessage 

func (*LastOffsetReply) ProtoMessage()

func (*LastOffsetReply) Reset 

func (m *LastOffsetReply) Reset()

func (*LastOffsetReply) Size 

func (m *LastOffsetReply) Size() (n int)

func (*LastOffsetReply) String 

func (this *LastOffsetReply) String() string

func (*LastOffsetReply) Unmarshal 

func (m *LastOffsetReply) Unmarshal(dAtA []byte) error

type LastOffsetRequest 

type LastOffsetRequest struct {
	Topic         string                 `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Partition     string                 `protobuf:"bytes,2,opt,name=partition,proto3" json:"partition,omitempty"`
	ConsumerGroup string                 `protobuf:"bytes,3,opt,name=consumerGroup,proto3" json:"consumerGroup,omitempty"`
	ConsumerName  string                 `protobuf:"bytes,4,opt,name=consumerName,proto3" json:"consumerName,omitempty"`
	Kind          LastOffsetRequest_Kind `protobuf:"varint,5,opt,name=kind,proto3,enum=sandglass.LastOffsetRequest_Kind" json:"kind,omitempty"`
}

func (*LastOffsetRequest) Descriptor 

func (*LastOffsetRequest) Descriptor() ([]byte, []int)

func (*LastOffsetRequest) Equal 

func (this *LastOffsetRequest) Equal(that interface{}) bool

func (*LastOffsetRequest) GetConsumerGroup 

func (m *LastOffsetRequest) GetConsumerGroup() string

func (*LastOffsetRequest) GetConsumerName 

func (m *LastOffsetRequest) GetConsumerName() string

func (*LastOffsetRequest) GetKind 

func (m *LastOffsetRequest) GetKind() LastOffsetRequest_Kind

func (*LastOffsetRequest) GetPartition 

func (m *LastOffsetRequest) GetPartition() string

func (*LastOffsetRequest) GetTopic 

func (m *LastOffsetRequest) GetTopic() string

func (*LastOffsetRequest) Marshal 

func (m *LastOffsetRequest) Marshal() (dAtA []byte, err error)

func (*LastOffsetRequest) MarshalTo 

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

func (*LastOffsetRequest) ProtoMessage 

func (*LastOffsetRequest) ProtoMessage()

func (*LastOffsetRequest) Reset 

func (m *LastOffsetRequest) Reset()

func (*LastOffsetRequest) Size 

func (m *LastOffsetRequest) Size() (n int)

func (*LastOffsetRequest) String 

func (this *LastOffsetRequest) String() string

func (*LastOffsetRequest) Unmarshal 

func (m *LastOffsetRequest) Unmarshal(dAtA []byte) error

type LastOffsetRequest_Kind 

type LastOffsetRequest_Kind int32
const (
	LastOffsetRequest_Unknown         LastOffsetRequest_Kind = 0
	LastOffsetRequest_Consumed        LastOffsetRequest_Kind = 10
	LastOffsetRequest_NotAcknowledged LastOffsetRequest_Kind = 20
	LastOffsetRequest_Acknowledged    LastOffsetRequest_Kind = 30
	LastOffsetRequest_Commited        LastOffsetRequest_Kind = 40
)

func (LastOffsetRequest_Kind) EnumDescriptor 

func (LastOffsetRequest_Kind) EnumDescriptor() ([]byte, []int)

func (LastOffsetRequest_Kind) String 

func (x LastOffsetRequest_Kind) String() string

type Message 

type Message struct {
	Topic     string                             `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Partition string                             `protobuf:"bytes,2,opt,name=partition,proto3" json:"partition,omitempty"`
	Index     github_com_celrenheit_sandflake.ID `protobuf:"bytes,3,opt,name=index,proto3,customtype=github.com/celrenheit/sandflake.ID" json:"index"`
	Offset    github_com_celrenheit_sandflake.ID `protobuf:"bytes,4,opt,name=offset,proto3,customtype=github.com/celrenheit/sandflake.ID" json:"offset"`
	Key       []byte                             `protobuf:"bytes,5,opt,name=key,proto3" json:"key,omitempty"`
	Value     []byte                             `protobuf:"bytes,6,opt,name=value,proto3" json:"value,omitempty"`
}

func (*Message) Descriptor 

func (*Message) Descriptor() ([]byte, []int)

func (*Message) Equal 

func (this *Message) Equal(that interface{}) bool

func (*Message) GetKey 

func (m *Message) GetKey() []byte

func (*Message) GetPartition 

func (m *Message) GetPartition() string

func (*Message) GetTopic 

func (m *Message) GetTopic() string

func (*Message) GetValue 

func (m *Message) GetValue() []byte

func (*Message) Marshal 

func (m *Message) Marshal() (dAtA []byte, err error)

func (*Message) MarshalTo 

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

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) Reset 

func (m *Message) Reset()

func (*Message) Size 

func (m *Message) Size() (n int)

func (*Message) String 

func (this *Message) String() string

func (*Message) Unmarshal 

func (m *Message) Unmarshal(dAtA []byte) error

type MultiOffsetChangeRequest 

type MultiOffsetChangeRequest struct {
	Topic         string                               `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Partition     string                               `protobuf:"bytes,2,opt,name=partition,proto3" json:"partition,omitempty"`
	ConsumerGroup string                               `protobuf:"bytes,3,opt,name=consumerGroup,proto3" json:"consumerGroup,omitempty"`
	ConsumerName  string                               `protobuf:"bytes,4,opt,name=consumerName,proto3" json:"consumerName,omitempty"`
	Offsets       []github_com_celrenheit_sandflake.ID `protobuf:"bytes,5,rep,name=offsets,customtype=github.com/celrenheit/sandflake.ID" json:"offsets"`
}

func (*MultiOffsetChangeRequest) Descriptor 

func (*MultiOffsetChangeRequest) Descriptor() ([]byte, []int)

func (*MultiOffsetChangeRequest) Equal 

func (this *MultiOffsetChangeRequest) Equal(that interface{}) bool

func (*MultiOffsetChangeRequest) GetConsumerGroup 

func (m *MultiOffsetChangeRequest) GetConsumerGroup() string

func (*MultiOffsetChangeRequest) GetConsumerName 

func (m *MultiOffsetChangeRequest) GetConsumerName() string

func (*MultiOffsetChangeRequest) GetPartition 

func (m *MultiOffsetChangeRequest) GetPartition() string

func (*MultiOffsetChangeRequest) GetTopic 

func (m *MultiOffsetChangeRequest) GetTopic() string

func (*MultiOffsetChangeRequest) Marshal 

func (m *MultiOffsetChangeRequest) Marshal() (dAtA []byte, err error)

func (*MultiOffsetChangeRequest) MarshalTo 

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

func (*MultiOffsetChangeRequest) ProtoMessage 

func (*MultiOffsetChangeRequest) ProtoMessage()

func (*MultiOffsetChangeRequest) Reset 

func (m *MultiOffsetChangeRequest) Reset()

func (*MultiOffsetChangeRequest) Size 

func (m *MultiOffsetChangeRequest) Size() (n int)

func (*MultiOffsetChangeRequest) String 

func (this *MultiOffsetChangeRequest) String() string

func (*MultiOffsetChangeRequest) Unmarshal 

func (m *MultiOffsetChangeRequest) Unmarshal(dAtA []byte) error

type OffsetChangeReply 

type OffsetChangeReply struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
}

func (*OffsetChangeReply) Descriptor 

func (*OffsetChangeReply) Descriptor() ([]byte, []int)

func (*OffsetChangeReply) Equal 

func (this *OffsetChangeReply) Equal(that interface{}) bool

func (*OffsetChangeReply) GetSuccess 

func (m *OffsetChangeReply) GetSuccess() bool

func (*OffsetChangeReply) Marshal 

func (m *OffsetChangeReply) Marshal() (dAtA []byte, err error)

func (*OffsetChangeReply) MarshalTo 

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

func (*OffsetChangeReply) ProtoMessage 

func (*OffsetChangeReply) ProtoMessage()

func (*OffsetChangeReply) Reset 

func (m *OffsetChangeReply) Reset()

func (*OffsetChangeReply) Size 

func (m *OffsetChangeReply) Size() (n int)

func (*OffsetChangeReply) String 

func (this *OffsetChangeReply) String() string

func (*OffsetChangeReply) Unmarshal 

func (m *OffsetChangeReply) Unmarshal(dAtA []byte) error

type OffsetChangeRequest 

type OffsetChangeRequest struct {
	Topic         string                             `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Partition     string                             `protobuf:"bytes,2,opt,name=partition,proto3" json:"partition,omitempty"`
	ConsumerGroup string                             `protobuf:"bytes,3,opt,name=consumerGroup,proto3" json:"consumerGroup,omitempty"`
	ConsumerName  string                             `protobuf:"bytes,4,opt,name=consumerName,proto3" json:"consumerName,omitempty"`
	Offset        github_com_celrenheit_sandflake.ID `protobuf:"bytes,5,opt,name=offset,proto3,customtype=github.com/celrenheit/sandflake.ID" json:"offset"`
}

func (*OffsetChangeRequest) Descriptor 

func (*OffsetChangeRequest) Descriptor() ([]byte, []int)

func (*OffsetChangeRequest) Equal 

func (this *OffsetChangeRequest) Equal(that interface{}) bool

func (*OffsetChangeRequest) GetConsumerGroup 

func (m *OffsetChangeRequest) GetConsumerGroup() string

func (*OffsetChangeRequest) GetConsumerName 

func (m *OffsetChangeRequest) GetConsumerName() string

func (*OffsetChangeRequest) GetPartition 

func (m *OffsetChangeRequest) GetPartition() string

func (*OffsetChangeRequest) GetTopic 

func (m *OffsetChangeRequest) GetTopic() string

func (*OffsetChangeRequest) Marshal 

func (m *OffsetChangeRequest) Marshal() (dAtA []byte, err error)

func (*OffsetChangeRequest) MarshalTo 

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

func (*OffsetChangeRequest) ProtoMessage 

func (*OffsetChangeRequest) ProtoMessage()

func (*OffsetChangeRequest) Reset 

func (m *OffsetChangeRequest) Reset()

func (*OffsetChangeRequest) Size 

func (m *OffsetChangeRequest) Size() (n int)

func (*OffsetChangeRequest) String 

func (this *OffsetChangeRequest) String() string

func (*OffsetChangeRequest) Unmarshal 

func (m *OffsetChangeRequest) Unmarshal(dAtA []byte) error

type StorageDriver 

type StorageDriver int32
const (
	StorageDriver_RocksDB StorageDriver = 0
	StorageDriver_Badger  StorageDriver = 1
)

func (StorageDriver) EnumDescriptor 

func (StorageDriver) EnumDescriptor() ([]byte, []int)

func (StorageDriver) String 

func (x StorageDriver) String() string

type StoreLocallyReply 

type StoreLocallyReply struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
}

func (*StoreLocallyReply) Descriptor 

func (*StoreLocallyReply) Descriptor() ([]byte, []int)

func (*StoreLocallyReply) Equal 

func (this *StoreLocallyReply) Equal(that interface{}) bool

func (*StoreLocallyReply) GetSuccess 

func (m *StoreLocallyReply) GetSuccess() bool

func (*StoreLocallyReply) Marshal 

func (m *StoreLocallyReply) Marshal() (dAtA []byte, err error)

func (*StoreLocallyReply) MarshalTo 

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

func (*StoreLocallyReply) ProtoMessage 

func (*StoreLocallyReply) ProtoMessage()

func (*StoreLocallyReply) Reset 

func (m *StoreLocallyReply) Reset()

func (*StoreLocallyReply) Size 

func (m *StoreLocallyReply) Size() (n int)

func (*StoreLocallyReply) String 

func (this *StoreLocallyReply) String() string

func (*StoreLocallyReply) Unmarshal 

func (m *StoreLocallyReply) Unmarshal(dAtA []byte) error

type SyncRequest 

type SyncRequest struct {
	Topics map[string]*SyncRequest_SyncRequestTopic `` /* 139-byte string literal not displayed */
}

func (*SyncRequest) Descriptor 

func (*SyncRequest) Descriptor() ([]byte, []int)

func (*SyncRequest) Equal 

func (this *SyncRequest) Equal(that interface{}) bool

func (*SyncRequest) GetTopics 

func (m *SyncRequest) GetTopics() map[string]*SyncRequest_SyncRequestTopic

func (*SyncRequest) Marshal 

func (m *SyncRequest) Marshal() (dAtA []byte, err error)

func (*SyncRequest) MarshalTo 

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

func (*SyncRequest) ProtoMessage 

func (*SyncRequest) ProtoMessage()

func (*SyncRequest) Reset 

func (m *SyncRequest) Reset()

func (*SyncRequest) Size 

func (m *SyncRequest) Size() (n int)

func (*SyncRequest) String 

func (this *SyncRequest) String() string

func (*SyncRequest) Unmarshal 

func (m *SyncRequest) Unmarshal(dAtA []byte) error

type SyncRequest_SyncRequestTopic 

type SyncRequest_SyncRequestTopic struct {
	Partitions []string `protobuf:"bytes,1,rep,name=partitions" json:"partitions,omitempty"`
}

func (*SyncRequest_SyncRequestTopic) Descriptor 

func (*SyncRequest_SyncRequestTopic) Descriptor() ([]byte, []int)

func (*SyncRequest_SyncRequestTopic) Equal 

func (this *SyncRequest_SyncRequestTopic) Equal(that interface{}) bool

func (*SyncRequest_SyncRequestTopic) GetPartitions 

func (m *SyncRequest_SyncRequestTopic) GetPartitions() []string

func (*SyncRequest_SyncRequestTopic) Marshal 

func (m *SyncRequest_SyncRequestTopic) Marshal() (dAtA []byte, err error)

func (*SyncRequest_SyncRequestTopic) MarshalTo 

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

func (*SyncRequest_SyncRequestTopic) ProtoMessage 

func (*SyncRequest_SyncRequestTopic) ProtoMessage()

func (*SyncRequest_SyncRequestTopic) Reset 

func (m *SyncRequest_SyncRequestTopic) Reset()

func (*SyncRequest_SyncRequestTopic) Size 

func (m *SyncRequest_SyncRequestTopic) Size() (n int)

func (*SyncRequest_SyncRequestTopic) String 

func (this *SyncRequest_SyncRequestTopic) String() string

func (*SyncRequest_SyncRequestTopic) Unmarshal 

func (m *SyncRequest_SyncRequestTopic) Unmarshal(dAtA []byte) error

type SyncResponse 

type SyncResponse struct {
	Topics map[string]*SyncResponse_SyncResponseTopic `` /* 139-byte string literal not displayed */
}

func (*SyncResponse) Descriptor 

func (*SyncResponse) Descriptor() ([]byte, []int)

func (*SyncResponse) Equal 

func (this *SyncResponse) Equal(that interface{}) bool

func (*SyncResponse) GetTopics 

func (m *SyncResponse) GetTopics() map[string]*SyncResponse_SyncResponseTopic

func (*SyncResponse) Marshal 

func (m *SyncResponse) Marshal() (dAtA []byte, err error)

func (*SyncResponse) MarshalTo 

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

func (*SyncResponse) ProtoMessage 

func (*SyncResponse) ProtoMessage()

func (*SyncResponse) Reset 

func (m *SyncResponse) Reset()

func (*SyncResponse) Size 

func (m *SyncResponse) Size() (n int)

func (*SyncResponse) String 

func (this *SyncResponse) String() string

func (*SyncResponse) Unmarshal 

func (m *SyncResponse) Unmarshal(dAtA []byte) error

type SyncResponse_SyncResponseTopic 

type SyncResponse_SyncResponseTopic struct {
	Partitions map[string]*Message `` /* 147-byte string literal not displayed */
}

func (*SyncResponse_SyncResponseTopic) Descriptor 

func (*SyncResponse_SyncResponseTopic) Descriptor() ([]byte, []int)

func (*SyncResponse_SyncResponseTopic) Equal 

func (this *SyncResponse_SyncResponseTopic) Equal(that interface{}) bool

func (*SyncResponse_SyncResponseTopic) GetPartitions 

func (m *SyncResponse_SyncResponseTopic) GetPartitions() map[string]*Message

func (*SyncResponse_SyncResponseTopic) Marshal 

func (m *SyncResponse_SyncResponseTopic) Marshal() (dAtA []byte, err error)

func (*SyncResponse_SyncResponseTopic) MarshalTo 

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

func (*SyncResponse_SyncResponseTopic) ProtoMessage 

func (*SyncResponse_SyncResponseTopic) ProtoMessage()

func (*SyncResponse_SyncResponseTopic) Reset 

func (m *SyncResponse_SyncResponseTopic) Reset()

func (*SyncResponse_SyncResponseTopic) Size 

func (m *SyncResponse_SyncResponseTopic) Size() (n int)

func (*SyncResponse_SyncResponseTopic) String 

func (this *SyncResponse_SyncResponseTopic) String() string

func (*SyncResponse_SyncResponseTopic) Unmarshal 

func (m *SyncResponse_SyncResponseTopic) Unmarshal(dAtA []byte) error

type TopicKind 

type TopicKind int32
const (
	TopicKind_TimerKind     TopicKind = 0
	TopicKind_CompactedKind TopicKind = 1
)

func (TopicKind) EnumDescriptor 

func (TopicKind) EnumDescriptor() ([]byte, []int)

func (TopicKind) String 

func (x TopicKind) String() string

type TopicReply 

type TopicReply struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
}

func (*TopicReply) Descriptor 

func (*TopicReply) Descriptor() ([]byte, []int)

func (*TopicReply) Equal 

func (this *TopicReply) Equal(that interface{}) bool

func (*TopicReply) GetSuccess 

func (m *TopicReply) GetSuccess() bool

func (*TopicReply) Marshal 

func (m *TopicReply) Marshal() (dAtA []byte, err error)

func (*TopicReply) MarshalTo 

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

func (*TopicReply) ProtoMessage 

func (*TopicReply) ProtoMessage()

func (*TopicReply) Reset 

func (m *TopicReply) Reset()

func (*TopicReply) Size 

func (m *TopicReply) Size() (n int)

func (*TopicReply) String 

func (this *TopicReply) String() string

func (*TopicReply) Unmarshal 

func (m *TopicReply) Unmarshal(dAtA []byte) error

Source Files

View all Source files

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.