sgproto

package
Version: 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: 10

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

Jump to

Keyboard shortcuts

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