sgproto

package
v0.0.0-...-79a076c Latest Latest
Warning

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

 Go to latest Published: Aug 25, 2018 License: Apache-2.0 Imports: 23 Imported by: 21

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
	ProduceMessageRequest
	ProduceResponse
	TopicConfig
	GetTopicParams
	GetTopicReply
	TopicReply
	StoreLocallyReply
	FetchFromRequest
	FetchRangeRequest
	GetRequest
	ConsumeFromGroupRequest
	MarkRequest
	MarkResponse
	GetMarkRequest
	LastOffsetReply
	LastOffsetRequest
	FetchFromSyncRequest
	HasResponse
	MarkState
	EndOfLogRequest
	EndOfLogReply

Package sgproto is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const Size = 6 + 8

Variables

View Source 
var (
	ErrInvalidLengthSandglass = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSandglass   = fmt.Errorf("proto: integer overflow")
)
View Source 
var MarkKind_name = map[int32]string{
	0:  "Unknown",
	10: "Consumed",
	20: "NotAcknowledged",
	30: "Acknowledged",
	40: "Commited",
}
View Source 
var MarkKind_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: "KVKind",
}
View Source 
var TopicKind_value = map[string]int32{
	"TimerKind": 0,
	"KVKind":    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 *TopicConfig, opts ...grpc.CallOption) (*TopicReply, error)
	GetTopic(ctx context.Context, in *GetTopicParams, opts ...grpc.CallOption) (*GetTopicReply, error)
	Produce(ctx context.Context, in *ProduceMessageRequest, opts ...grpc.CallOption) (*ProduceResponse, 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)
	ConsumeFromGroup(ctx context.Context, in *ConsumeFromGroupRequest, opts ...grpc.CallOption) (BrokerService_ConsumeFromGroupClient, error)
	Acknowledge(ctx context.Context, in *MarkRequest, opts ...grpc.CallOption) (*MarkResponse, error)
	NotAcknowledge(ctx context.Context, in *MarkRequest, opts ...grpc.CallOption) (*MarkResponse, error)
}

func NewBrokerServiceClient 

func NewBrokerServiceClient(cc *grpc.ClientConn) BrokerServiceClient

type BrokerServiceServer 

type BrokerServiceServer interface {
	CreateTopic(context.Context, *TopicConfig) (*TopicReply, error)
	GetTopic(context.Context, *GetTopicParams) (*GetTopicReply, error)
	Produce(context.Context, *ProduceMessageRequest) (*ProduceResponse, error)
	FetchFrom(*FetchFromRequest, BrokerService_FetchFromServer) error
	FetchRange(*FetchRangeRequest, BrokerService_FetchRangeServer) error
	ConsumeFromGroup(*ConsumeFromGroupRequest, BrokerService_ConsumeFromGroupServer) error
	Acknowledge(context.Context, *MarkRequest) (*MarkResponse, error)
	NotAcknowledge(context.Context, *MarkRequest) (*MarkResponse, 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 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"`
	Channel           string `protobuf:"bytes,5,opt,name=channel,proto3" json:"channel,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) GetChannel 

func (m *ConsumeFromGroupRequest) GetChannel() string

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 EndOfLogReply 

type EndOfLogReply struct {
	Index uint64 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
}

func (*EndOfLogReply) Descriptor 

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

func (*EndOfLogReply) Equal 

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

func (*EndOfLogReply) GetIndex 

func (m *EndOfLogReply) GetIndex() uint64

func (*EndOfLogReply) Marshal 

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

func (*EndOfLogReply) MarshalTo 

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

func (*EndOfLogReply) ProtoMessage 

func (*EndOfLogReply) ProtoMessage()

func (*EndOfLogReply) Reset 

func (m *EndOfLogReply) Reset()

func (*EndOfLogReply) Size 

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

func (*EndOfLogReply) String 

func (this *EndOfLogReply) String() string

func (*EndOfLogReply) Unmarshal 

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

type EndOfLogRequest 

type EndOfLogRequest 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"`
}

func (*EndOfLogRequest) Descriptor 

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

func (*EndOfLogRequest) Equal 

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

func (*EndOfLogRequest) GetPartition 

func (m *EndOfLogRequest) GetPartition() string

func (*EndOfLogRequest) GetTopic 

func (m *EndOfLogRequest) GetTopic() string

func (*EndOfLogRequest) Marshal 

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

func (*EndOfLogRequest) MarshalTo 

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

func (*EndOfLogRequest) ProtoMessage 

func (*EndOfLogRequest) ProtoMessage()

func (*EndOfLogRequest) Reset 

func (m *EndOfLogRequest) Reset()

func (*EndOfLogRequest) Size 

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

func (*EndOfLogRequest) String 

func (this *EndOfLogRequest) String() string

func (*EndOfLogRequest) Unmarshal 

func (m *EndOfLogRequest) 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"`
	Channel   string `protobuf:"bytes,4,opt,name=channel,proto3" json:"channel,omitempty"`
	From      Offset `protobuf:"bytes,3,opt,name=from,proto3,customtype=Offset" json:"from"`
}

func (*FetchFromRequest) Descriptor 

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

func (*FetchFromRequest) Equal 

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

func (*FetchFromRequest) GetChannel 

func (m *FetchFromRequest) GetChannel() string

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"`
	Channel   string `protobuf:"bytes,5,opt,name=channel,proto3" json:"channel,omitempty"`
	From      Offset `protobuf:"bytes,3,opt,name=from,proto3,customtype=Offset" json:"from"`
	To        Offset `protobuf:"bytes,4,opt,name=to,proto3,customtype=Offset" json:"to"`
}

func (*FetchRangeRequest) Descriptor 

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

func (*FetchRangeRequest) Equal 

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

func (*FetchRangeRequest) GetChannel 

func (m *FetchRangeRequest) GetChannel() string

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 GetMarkRequest 

type GetMarkRequest 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"`
	Channel       string `protobuf:"bytes,6,opt,name=channel,proto3" json:"channel,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        Offset `protobuf:"bytes,5,opt,name=offset,proto3,customtype=Offset" json:"offset"`
}

func (*GetMarkRequest) Descriptor 

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

func (*GetMarkRequest) Equal 

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

func (*GetMarkRequest) GetChannel 

func (m *GetMarkRequest) GetChannel() string

func (*GetMarkRequest) GetConsumerGroup 

func (m *GetMarkRequest) GetConsumerGroup() string

func (*GetMarkRequest) GetConsumerName 

func (m *GetMarkRequest) GetConsumerName() string

func (*GetMarkRequest) GetPartition 

func (m *GetMarkRequest) GetPartition() string

func (*GetMarkRequest) GetTopic 

func (m *GetMarkRequest) GetTopic() string

func (*GetMarkRequest) Marshal 

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

func (*GetMarkRequest) MarshalTo 

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

func (*GetMarkRequest) ProtoMessage 

func (*GetMarkRequest) ProtoMessage()

func (*GetMarkRequest) Reset 

func (m *GetMarkRequest) Reset()

func (*GetMarkRequest) Size 

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

func (*GetMarkRequest) String 

func (this *GetMarkRequest) String() string

func (*GetMarkRequest) Unmarshal 

func (m *GetMarkRequest) 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"`
	Channel       string `protobuf:"bytes,5,opt,name=channel,proto3" json:"channel,omitempty"`
	Key           []byte `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	ClusteringKey []byte `protobuf:"bytes,4,opt,name=clusteringKey,proto3" json:"clusteringKey,omitempty"`
}

func (*GetRequest) Descriptor 

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

func (*GetRequest) Equal 

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

func (*GetRequest) GetChannel 

func (m *GetRequest) GetChannel() string

func (*GetRequest) GetClusteringKey 

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

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 {
	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)
	Mark(ctx context.Context, in *MarkRequest, opts ...grpc.CallOption) (*MarkResponse, error)
	GetMarkStateMessage(ctx context.Context, in *GetMarkRequest, opts ...grpc.CallOption) (*Message, error)
	EndOfLog(ctx context.Context, in *EndOfLogRequest, opts ...grpc.CallOption) (*EndOfLogReply, error)
}

func NewInternalServiceClient 

func NewInternalServiceClient(cc *grpc.ClientConn) InternalServiceClient

type InternalServiceServer 

type InternalServiceServer interface {
	GetByKey(context.Context, *GetRequest) (*Message, error)
	HasKey(context.Context, *GetRequest) (*HasResponse, error)
	FetchFromSync(*FetchFromSyncRequest, InternalService_FetchFromSyncServer) error
	LastOffset(context.Context, *LastOffsetRequest) (*LastOffsetReply, error)
	Mark(context.Context, *MarkRequest) (*MarkResponse, error)
	GetMarkStateMessage(context.Context, *GetMarkRequest) (*Message, error)
	EndOfLog(context.Context, *EndOfLogRequest) (*EndOfLogReply, 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 Offset `protobuf:"bytes,1,opt,name=offset,proto3,customtype=Offset" 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"`
	Channel       string   `protobuf:"bytes,6,opt,name=channel,proto3" json:"channel,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          MarkKind `protobuf:"varint,5,opt,name=kind,proto3,enum=sandglass.MarkKind" json:"kind,omitempty"`
}

func (*LastOffsetRequest) Descriptor 

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

func (*LastOffsetRequest) Equal 

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

func (*LastOffsetRequest) GetChannel 

func (m *LastOffsetRequest) GetChannel() string

func (*LastOffsetRequest) GetConsumerGroup 

func (m *LastOffsetRequest) GetConsumerGroup() string

func (*LastOffsetRequest) GetConsumerName 

func (m *LastOffsetRequest) GetConsumerName() string

func (*LastOffsetRequest) GetKind 

func (m *LastOffsetRequest) GetKind() MarkKind

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 MarkKind 

type MarkKind int32
const (
	MarkKind_Unknown         MarkKind = 0
	MarkKind_Consumed        MarkKind = 10
	MarkKind_NotAcknowledged MarkKind = 20
	MarkKind_Acknowledged    MarkKind = 30
	MarkKind_Commited        MarkKind = 40
)

func (MarkKind) EnumDescriptor 

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

func (MarkKind) String 

func (x MarkKind) String() string

type MarkRequest 

type MarkRequest 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"`
	Channel       string     `protobuf:"bytes,7,opt,name=channel,proto3" json:"channel,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       []Offset   `protobuf:"bytes,5,rep,name=offsets,customtype=Offset" json:"offsets"`
	State         *MarkState `protobuf:"bytes,6,opt,name=state" json:"state,omitempty"`
}

func (*MarkRequest) Descriptor 

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

func (*MarkRequest) Equal 

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

func (*MarkRequest) GetChannel 

func (m *MarkRequest) GetChannel() string

func (*MarkRequest) GetConsumerGroup 

func (m *MarkRequest) GetConsumerGroup() string

func (*MarkRequest) GetConsumerName 

func (m *MarkRequest) GetConsumerName() string

func (*MarkRequest) GetPartition 

func (m *MarkRequest) GetPartition() string

func (*MarkRequest) GetState 

func (m *MarkRequest) GetState() *MarkState

func (*MarkRequest) GetTopic 

func (m *MarkRequest) GetTopic() string

func (*MarkRequest) Marshal 

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

func (*MarkRequest) MarshalTo 

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

func (*MarkRequest) ProtoMessage 

func (*MarkRequest) ProtoMessage()

func (*MarkRequest) Reset 

func (m *MarkRequest) Reset()

func (*MarkRequest) Size 

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

func (*MarkRequest) String 

func (this *MarkRequest) String() string

func (*MarkRequest) Unmarshal 

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

type MarkResponse 

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

func (*MarkResponse) Descriptor 

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

func (*MarkResponse) Equal 

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

func (*MarkResponse) GetSuccess 

func (m *MarkResponse) GetSuccess() bool

func (*MarkResponse) Marshal 

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

func (*MarkResponse) MarshalTo 

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

func (*MarkResponse) ProtoMessage 

func (*MarkResponse) ProtoMessage()

func (*MarkResponse) Reset 

func (m *MarkResponse) Reset()

func (*MarkResponse) Size 

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

func (*MarkResponse) String 

func (this *MarkResponse) String() string

func (*MarkResponse) Unmarshal 

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

type MarkState 

type MarkState struct {
	Kind          MarkKind `protobuf:"varint,1,opt,name=kind,proto3,enum=sandglass.MarkKind" json:"kind,omitempty"`
	DeliveryCount int32    `protobuf:"varint,2,opt,name=deliveryCount,proto3" json:"deliveryCount,omitempty"`
}

func (*MarkState) Descriptor 

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

func (*MarkState) Equal 

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

func (*MarkState) GetDeliveryCount 

func (m *MarkState) GetDeliveryCount() int32

func (*MarkState) GetKind 

func (m *MarkState) GetKind() MarkKind

func (*MarkState) Marshal 

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

func (*MarkState) MarshalTo 

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

func (*MarkState) ProtoMessage 

func (*MarkState) ProtoMessage()

func (*MarkState) Reset 

func (m *MarkState) Reset()

func (*MarkState) Size 

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

func (*MarkState) String 

func (this *MarkState) String() string

func (*MarkState) Unmarshal 

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

type Message 

type Message struct {
	Channel       string        `protobuf:"bytes,5,opt,name=channel,proto3" json:"channel,omitempty"`
	Index         uint64        `protobuf:"varint,10,opt,name=index,proto3" json:"index,omitempty"`
	Offset        Offset        `protobuf:"bytes,11,opt,name=offset,proto3,customtype=Offset" json:"offset"`
	ProducedAt    time.Time     `protobuf:"bytes,12,opt,name=producedAt,stdtime" json:"producedAt"`
	ConsumeIn     time.Duration `protobuf:"bytes,13,opt,name=consumeIn,stdduration" json:"consumeIn"`
	Key           []byte        `protobuf:"bytes,20,opt,name=key,proto3" json:"key,omitempty"`
	ClusteringKey []byte        `protobuf:"bytes,21,opt,name=clusteringKey,proto3" json:"clusteringKey,omitempty"`
	Value         []byte        `protobuf:"bytes,30,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) GetChannel 

func (m *Message) GetChannel() string

func (*Message) GetClusteringKey 

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

func (*Message) GetConsumeIn 

func (m *Message) GetConsumeIn() time.Duration

func (*Message) GetIndex 

func (m *Message) GetIndex() uint64

func (*Message) GetKey 

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

func (*Message) GetProducedAt 

func (m *Message) GetProducedAt() time.Time

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 Offset 

type Offset [Size]byte
var (
	Nil       Offset
	MaxOffset Offset = [Size]byte{0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF}
)

func NewOffset 

func NewOffset(index uint64, displayTime time.Time) Offset

func (Offset) After 

func (this Offset) After(that Offset) bool

func (Offset) Before 

func (this Offset) Before(that Offset) bool

func (Offset) Bytes 

func (o Offset) Bytes() []byte

func (Offset) Equal 

func (this Offset) Equal(that Offset) bool

func (Offset) Index 

func (d Offset) Index() uint64

func (Offset) Marshal 

func (d Offset) Marshal() ([]byte, error)

func (Offset) MarshalTo 

func (d Offset) MarshalTo(dst []byte) (int, error)

func (Offset) Size 

func (_ Offset) Size() int

func (Offset) String 

func (o Offset) String() string

func (Offset) Time 

func (o Offset) Time() time.Time

func (*Offset) Unmarshal 

func (d *Offset) Unmarshal(b []byte) error

type ProduceMessageRequest 

type ProduceMessageRequest 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"`
	Messages  []*Message `protobuf:"bytes,3,rep,name=messages" json:"messages,omitempty"`
}

func (*ProduceMessageRequest) Descriptor 

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

func (*ProduceMessageRequest) Equal 

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

func (*ProduceMessageRequest) GetMessages 

func (m *ProduceMessageRequest) GetMessages() []*Message

func (*ProduceMessageRequest) GetPartition 

func (m *ProduceMessageRequest) GetPartition() string

func (*ProduceMessageRequest) GetTopic 

func (m *ProduceMessageRequest) GetTopic() string

func (*ProduceMessageRequest) Marshal 

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

func (*ProduceMessageRequest) MarshalTo 

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

func (*ProduceMessageRequest) ProtoMessage 

func (*ProduceMessageRequest) ProtoMessage()

func (*ProduceMessageRequest) Reset 

func (m *ProduceMessageRequest) Reset()

func (*ProduceMessageRequest) Size 

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

func (*ProduceMessageRequest) String 

func (this *ProduceMessageRequest) String() string

func (*ProduceMessageRequest) Unmarshal 

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

type ProduceResponse 

type ProduceResponse struct {
	Offsets []Offset `protobuf:"bytes,1,rep,name=offsets,customtype=Offset" json:"offsets"`
}

func (*ProduceResponse) Descriptor 

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

func (*ProduceResponse) Equal 

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

func (*ProduceResponse) Marshal 

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

func (*ProduceResponse) MarshalTo 

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

func (*ProduceResponse) ProtoMessage 

func (*ProduceResponse) ProtoMessage()

func (*ProduceResponse) Reset 

func (m *ProduceResponse) Reset()

func (*ProduceResponse) Size 

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

func (*ProduceResponse) String 

func (this *ProduceResponse) String() string

func (*ProduceResponse) Unmarshal 

func (m *ProduceResponse) 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 TopicConfig 

type TopicConfig 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 (*TopicConfig) Descriptor 

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

func (*TopicConfig) Equal 

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

func (*TopicConfig) GetKind 

func (m *TopicConfig) GetKind() TopicKind

func (*TopicConfig) GetName 

func (m *TopicConfig) GetName() string

func (*TopicConfig) GetNumPartitions 

func (m *TopicConfig) GetNumPartitions() int32

func (*TopicConfig) GetReplicationFactor 

func (m *TopicConfig) GetReplicationFactor() int32

func (*TopicConfig) GetStorageDriver 

func (m *TopicConfig) GetStorageDriver() StorageDriver

func (*TopicConfig) Marshal 

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

func (*TopicConfig) MarshalTo 

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

func (*TopicConfig) ProtoMessage 

func (*TopicConfig) ProtoMessage()

func (*TopicConfig) Reset 

func (m *TopicConfig) Reset()

func (*TopicConfig) Size 

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

func (*TopicConfig) String 

func (this *TopicConfig) String() string

func (*TopicConfig) Unmarshal 

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

type TopicKind 

type TopicKind int32
const (
	TopicKind_TimerKind TopicKind = 0
	TopicKind_KVKind    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.