pb

package

Go to main page

Versions in this module

v0

v0.16.0

Nov 23, 2018

Changes in this version

type ConsRs

+ Headers []*RecordHeader

+ func (m *ConsRs) GetHeaders() []*RecordHeader

type ProdRq

+ Headers []*RecordHeader

+ func (m *ProdRq) GetHeaders() []*RecordHeader

+ type RecordHeader struct

+ Key string

+ Value []byte

+ func (*RecordHeader) Descriptor() ([]byte, []int)

+ func (*RecordHeader) ProtoMessage()

+ func (m *RecordHeader) GetKey() string

+ func (m *RecordHeader) GetValue() []byte

+ func (m *RecordHeader) Reset()

+ func (m *RecordHeader) String() string

v0.15.0

Mar 30, 2018

Changes in this version

+ type ConsumerGroups struct

+ Consumers map[string]*ConsumerPartitions

+ func (*ConsumerGroups) Descriptor() ([]byte, []int)

+ func (*ConsumerGroups) ProtoMessage()

+ func (m *ConsumerGroups) GetConsumers() map[string]*ConsumerPartitions

+ func (m *ConsumerGroups) Reset()

+ func (m *ConsumerGroups) String() string

+ type ConsumerPartitions struct

+ Partitions []int32

+ func (*ConsumerPartitions) Descriptor() ([]byte, []int)

+ func (*ConsumerPartitions) ProtoMessage()

+ func (m *ConsumerPartitions) GetPartitions() []int32

+ func (m *ConsumerPartitions) Reset()

+ func (m *ConsumerPartitions) String() string

+ type GetTopicMetadataRq struct

+ Cluster string

+ Topic string

+ WithPartitions bool

+ func (*GetTopicMetadataRq) Descriptor() ([]byte, []int)

+ func (*GetTopicMetadataRq) ProtoMessage()

+ func (m *GetTopicMetadataRq) GetCluster() string

+ func (m *GetTopicMetadataRq) GetTopic() string

+ func (m *GetTopicMetadataRq) GetWithPartitions() bool

+ func (m *GetTopicMetadataRq) Reset()

+ func (m *GetTopicMetadataRq) String() string

+ type GetTopicMetadataRs struct

+ Config map[string]string

+ Partitions []*PartitionMetadata

+ Version int32

+ func (*GetTopicMetadataRs) Descriptor() ([]byte, []int)

+ func (*GetTopicMetadataRs) ProtoMessage()

+ func (m *GetTopicMetadataRs) GetConfig() map[string]string

+ func (m *GetTopicMetadataRs) GetPartitions() []*PartitionMetadata

+ func (m *GetTopicMetadataRs) GetVersion() int32

+ func (m *GetTopicMetadataRs) Reset()

+ func (m *GetTopicMetadataRs) String() string

type KafkaPixyClient

+ GetTopicMetadata func(ctx context.Context, in *GetTopicMetadataRq, opts ...grpc.CallOption) (*GetTopicMetadataRs, error)

+ ListConsumers func(ctx context.Context, in *ListConsumersRq, opts ...grpc.CallOption) (*ListConsumersRs, error)

+ ListTopics func(ctx context.Context, in *ListTopicRq, opts ...grpc.CallOption) (*ListTopicRs, error)

+ SetOffsets func(ctx context.Context, in *SetOffsetsRq, opts ...grpc.CallOption) (*SetOffsetsRs, error)

type KafkaPixyServer

+ GetTopicMetadata func(context.Context, *GetTopicMetadataRq) (*GetTopicMetadataRs, error)

+ ListConsumers func(context.Context, *ListConsumersRq) (*ListConsumersRs, error)

+ ListTopics func(context.Context, *ListTopicRq) (*ListTopicRs, error)

+ SetOffsets func(context.Context, *SetOffsetsRq) (*SetOffsetsRs, error)

+ type ListConsumersRq struct

+ Cluster string

+ Group string

+ Topic string

+ func (*ListConsumersRq) Descriptor() ([]byte, []int)

+ func (*ListConsumersRq) ProtoMessage()

+ func (m *ListConsumersRq) GetCluster() string

+ func (m *ListConsumersRq) GetGroup() string

+ func (m *ListConsumersRq) GetTopic() string

+ func (m *ListConsumersRq) Reset()

+ func (m *ListConsumersRq) String() string

+ type ListConsumersRs struct

+ Groups map[string]*ConsumerGroups

+ func (*ListConsumersRs) Descriptor() ([]byte, []int)

+ func (*ListConsumersRs) ProtoMessage()

+ func (m *ListConsumersRs) GetGroups() map[string]*ConsumerGroups

+ func (m *ListConsumersRs) Reset()

+ func (m *ListConsumersRs) String() string

+ type ListTopicRq struct

+ Cluster string

+ WithPartitions bool

+ func (*ListTopicRq) Descriptor() ([]byte, []int)

+ func (*ListTopicRq) ProtoMessage()

+ func (m *ListTopicRq) GetCluster() string

+ func (m *ListTopicRq) GetWithPartitions() bool

+ func (m *ListTopicRq) Reset()

+ func (m *ListTopicRq) String() string

+ type ListTopicRs struct

+ Topics map[string]*GetTopicMetadataRs

+ func (*ListTopicRs) Descriptor() ([]byte, []int)

+ func (*ListTopicRs) ProtoMessage()

+ func (m *ListTopicRs) GetTopics() map[string]*GetTopicMetadataRs

+ func (m *ListTopicRs) Reset()

+ func (m *ListTopicRs) String() string

+ type PartitionMetadata struct

+ Isr []int32

+ Leader int32

+ Partition int32

+ Replicas []int32

+ func (*PartitionMetadata) Descriptor() ([]byte, []int)

+ func (*PartitionMetadata) ProtoMessage()

+ func (m *PartitionMetadata) GetIsr() []int32

+ func (m *PartitionMetadata) GetLeader() int32

+ func (m *PartitionMetadata) GetPartition() int32

+ func (m *PartitionMetadata) GetReplicas() []int32

+ func (m *PartitionMetadata) Reset()

+ func (m *PartitionMetadata) String() string

+ type SetOffsetsRq struct

+ Cluster string

+ Group string

+ Offsets []*PartitionOffset

+ Topic string

+ func (*SetOffsetsRq) Descriptor() ([]byte, []int)

+ func (*SetOffsetsRq) ProtoMessage()

+ func (m *SetOffsetsRq) GetCluster() string

+ func (m *SetOffsetsRq) GetGroup() string

+ func (m *SetOffsetsRq) GetOffsets() []*PartitionOffset

+ func (m *SetOffsetsRq) GetTopic() string

+ func (m *SetOffsetsRq) Reset()

+ func (m *SetOffsetsRq) String() string

+ type SetOffsetsRs struct

+ func (*SetOffsetsRs) Descriptor() ([]byte, []int)

+ func (*SetOffsetsRs) ProtoMessage()

+ func (m *SetOffsetsRs) Reset()

+ func (m *SetOffsetsRs) String() string

v0.14.0

Sep 11, 2017

Changes in this version

+ type GetOffsetsRq struct

+ Cluster string

+ Group string

+ Topic string

+ func (*GetOffsetsRq) Descriptor() ([]byte, []int)

+ func (*GetOffsetsRq) ProtoMessage()

+ func (m *GetOffsetsRq) GetCluster() string

+ func (m *GetOffsetsRq) GetGroup() string

+ func (m *GetOffsetsRq) GetTopic() string

+ func (m *GetOffsetsRq) Reset()

+ func (m *GetOffsetsRq) String() string

+ type GetOffsetsRs struct

+ Offsets []*PartitionOffset

+ func (*GetOffsetsRs) Descriptor() ([]byte, []int)

+ func (*GetOffsetsRs) ProtoMessage()

+ func (m *GetOffsetsRs) GetOffsets() []*PartitionOffset

+ func (m *GetOffsetsRs) Reset()

+ func (m *GetOffsetsRs) String() string

type KafkaPixyClient

+ GetOffsets func(ctx context.Context, in *GetOffsetsRq, opts ...grpc.CallOption) (*GetOffsetsRs, error)

type KafkaPixyServer

+ GetOffsets func(context.Context, *GetOffsetsRq) (*GetOffsetsRs, error)

+ type PartitionOffset struct

+ Begin int64

+ Count int64

+ End int64

+ Lag int64

+ Metadata string

+ Offset int64

+ Partition int32

+ SparseAcks string

+ func (*PartitionOffset) Descriptor() ([]byte, []int)

+ func (*PartitionOffset) ProtoMessage()

+ func (m *PartitionOffset) GetBegin() int64

+ func (m *PartitionOffset) GetCount() int64

+ func (m *PartitionOffset) GetEnd() int64

+ func (m *PartitionOffset) GetLag() int64

+ func (m *PartitionOffset) GetMetadata() string

+ func (m *PartitionOffset) GetOffset() int64

+ func (m *PartitionOffset) GetPartition() int32

+ func (m *PartitionOffset) GetSparseAcks() string

+ func (m *PartitionOffset) Reset()

+ func (m *PartitionOffset) String() string

v0.13.0

Mar 23, 2017

Changes in this version

+ type AckRq struct

+ Cluster string

+ Group string

+ Offset int64

+ Partition int32

+ Topic string

+ func (*AckRq) Descriptor() ([]byte, []int)

+ func (*AckRq) ProtoMessage()

+ func (m *AckRq) GetCluster() string

+ func (m *AckRq) GetGroup() string

+ func (m *AckRq) GetOffset() int64

+ func (m *AckRq) GetPartition() int32

+ func (m *AckRq) GetTopic() string

+ func (m *AckRq) Reset()

+ func (m *AckRq) String() string

+ type AckRs struct

+ func (*AckRs) Descriptor() ([]byte, []int)

+ func (*AckRs) ProtoMessage()

+ func (m *AckRs) Reset()

+ func (m *AckRs) String() string

+ type ConsNAckRq struct

+ AckOffset int64

+ AckPartition int32

+ AutoAck bool

+ Cluster string

+ Group string

+ NoAck bool

+ Topic string

+ func (*ConsNAckRq) Descriptor() ([]byte, []int)

+ func (*ConsNAckRq) ProtoMessage()

+ func (m *ConsNAckRq) GetAckOffset() int64

+ func (m *ConsNAckRq) GetAckPartition() int32

+ func (m *ConsNAckRq) GetAutoAck() bool

+ func (m *ConsNAckRq) GetCluster() string

+ func (m *ConsNAckRq) GetGroup() string

+ func (m *ConsNAckRq) GetNoAck() bool

+ func (m *ConsNAckRq) GetTopic() string

+ func (m *ConsNAckRq) Reset()

+ func (m *ConsNAckRq) String() string

+ type ConsRs struct

+ KeyUndefined bool

+ KeyValue []byte

+ Message []byte

+ Offset int64

+ Partition int32

+ func (*ConsRs) Descriptor() ([]byte, []int)

+ func (*ConsRs) ProtoMessage()

+ func (m *ConsRs) GetKeyUndefined() bool

+ func (m *ConsRs) GetKeyValue() []byte

+ func (m *ConsRs) GetMessage() []byte

+ func (m *ConsRs) GetOffset() int64

+ func (m *ConsRs) GetPartition() int32

+ func (m *ConsRs) Reset()

+ func (m *ConsRs) String() string

type KafkaPixyClient

+ Ack func(ctx context.Context, in *AckRq, opts ...grpc.CallOption) (*AckRs, error)

+ ConsumeNAck func(ctx context.Context, in *ConsNAckRq, opts ...grpc.CallOption) (*ConsRs, error)

type KafkaPixyServer

+ Ack func(context.Context, *AckRq) (*AckRs, error)

+ ConsumeNAck func(context.Context, *ConsNAckRq) (*ConsRs, error)

+ type ProdRq struct

+ AsyncMode bool

+ Cluster string

+ KeyUndefined bool

+ KeyValue []byte

+ Message []byte

+ Topic string

+ func (*ProdRq) Descriptor() ([]byte, []int)

+ func (*ProdRq) ProtoMessage()

+ func (m *ProdRq) GetAsyncMode() bool

+ func (m *ProdRq) GetCluster() string

+ func (m *ProdRq) GetKeyUndefined() bool

+ func (m *ProdRq) GetKeyValue() []byte

+ func (m *ProdRq) GetMessage() []byte

+ func (m *ProdRq) GetTopic() string

+ func (m *ProdRq) Reset()

+ func (m *ProdRq) String() string

+ type ProdRs struct

+ Offset int64

+ Partition int32

+ func (*ProdRs) Descriptor() ([]byte, []int)

+ func (*ProdRs) ProtoMessage()

+ func (m *ProdRs) GetOffset() int64

+ func (m *ProdRs) GetPartition() int32

+ func (m *ProdRs) Reset()

+ func (m *ProdRs) String() string

v0.12.0

Feb 22, 2017

Changes in this version

+ func RegisterKafkaPixyServer(s *grpc.Server, srv KafkaPixyServer)

+ type ConsReq struct

+ Group string

+ Proxy string

+ Topic string

+ func (*ConsReq) Descriptor() ([]byte, []int)

+ func (*ConsReq) ProtoMessage()

+ func (m *ConsReq) GetGroup() string

+ func (m *ConsReq) GetProxy() string

+ func (m *ConsReq) GetTopic() string

+ func (m *ConsReq) Reset()

+ func (m *ConsReq) String() string

+ type ConsRes struct

+ KeyUndefined bool

+ KeyValue []byte

+ Message []byte

+ Offset int64

+ Partition int32

+ func (*ConsRes) Descriptor() ([]byte, []int)

+ func (*ConsRes) ProtoMessage()

+ func (m *ConsRes) GetKeyUndefined() bool

+ func (m *ConsRes) GetKeyValue() []byte

+ func (m *ConsRes) GetMessage() []byte

+ func (m *ConsRes) GetOffset() int64

+ func (m *ConsRes) GetPartition() int32

+ func (m *ConsRes) Reset()

+ func (m *ConsRes) String() string

+ type KafkaPixyClient interface

+ Consume func(ctx context.Context, in *ConsReq, opts ...grpc.CallOption) (*ConsRes, error)

+ Produce func(ctx context.Context, in *ProdReq, opts ...grpc.CallOption) (*ProdRes, error)

+ func NewKafkaPixyClient(cc *grpc.ClientConn) KafkaPixyClient

+ type KafkaPixyServer interface

+ Consume func(context.Context, *ConsReq) (*ConsRes, error)

+ Produce func(context.Context, *ProdReq) (*ProdRes, error)

+ type ProdReq struct

+ AsyncMode bool

+ KeyUndefined bool

+ KeyValue []byte

+ Message []byte

+ Proxy string

+ Topic string

+ func (*ProdReq) Descriptor() ([]byte, []int)

+ func (*ProdReq) ProtoMessage()

+ func (m *ProdReq) GetAsyncMode() bool

+ func (m *ProdReq) GetKeyUndefined() bool

+ func (m *ProdReq) GetKeyValue() []byte

+ func (m *ProdReq) GetMessage() []byte

+ func (m *ProdReq) GetProxy() string

+ func (m *ProdReq) GetTopic() string

+ func (m *ProdReq) Reset()

+ func (m *ProdReq) String() string

+ type ProdRes struct

+ Offset int64

+ Partition int32

+ func (*ProdRes) Descriptor() ([]byte, []int)

+ func (*ProdRes) ProtoMessage()

+ func (m *ProdRes) GetOffset() int64

+ func (m *ProdRes) GetPartition() int32

+ func (m *ProdRes) Reset()

+ func (m *ProdRes) String() string

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