wkafka

package
v0.3.4 Latest Latest
Warning

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

 Go to latest Published: Oct 22, 2024 License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	SkipOption_name = map[int32]string{
		0: "APPEND",
		1: "REPLACE",
	}
	SkipOption_value = map[string]int32{
		"APPEND":  0,
		"REPLACE": 1,
	}
)

Enum value maps for SkipOption.

View Source 
var File_wkafka_wkafka_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type CreateSkipRequest 

type CreateSkipRequest struct {
	Topics map[string]*Topic `` /* 153-byte string literal not displayed */
	Option SkipOption        `protobuf:"varint,2,opt,name=option,proto3,enum=wkafka.SkipOption" json:"option,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateSkipRequest) Descriptor deprecated 

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

Deprecated: Use CreateSkipRequest.ProtoReflect.Descriptor instead.

func (*CreateSkipRequest) GetOption 

func (x *CreateSkipRequest) GetOption() SkipOption

func (*CreateSkipRequest) GetTopics 

func (x *CreateSkipRequest) GetTopics() map[string]*Topic

func (*CreateSkipRequest) ProtoMessage 

func (*CreateSkipRequest) ProtoMessage()

func (*CreateSkipRequest) ProtoReflect 

func (x *CreateSkipRequest) ProtoReflect() protoreflect.Message

func (*CreateSkipRequest) Reset 

func (x *CreateSkipRequest) Reset()

func (*CreateSkipRequest) String 

func (x *CreateSkipRequest) String() string

type DLQMessage added in v0.3.4 

type DLQMessage struct {
	Topic     string            `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Partition int32             `protobuf:"varint,2,opt,name=partition,proto3" json:"partition,omitempty"`
	Offset    int64             `protobuf:"varint,3,opt,name=offset,proto3" json:"offset,omitempty"`
	Key       string            `protobuf:"bytes,4,opt,name=key,proto3" json:"key,omitempty"`
	Value     string            `protobuf:"bytes,5,opt,name=value,proto3" json:"value,omitempty"`
	Timestamp string            `protobuf:"bytes,6,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Headers   map[string]string `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*DLQMessage) Descriptor deprecated added in v0.3.4 

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

Deprecated: Use DLQMessage.ProtoReflect.Descriptor instead.

func (*DLQMessage) GetHeaders added in v0.3.4 

func (x *DLQMessage) GetHeaders() map[string]string

func (*DLQMessage) GetKey added in v0.3.4 

func (x *DLQMessage) GetKey() string

func (*DLQMessage) GetOffset added in v0.3.4 

func (x *DLQMessage) GetOffset() int64

func (*DLQMessage) GetPartition added in v0.3.4 

func (x *DLQMessage) GetPartition() int32

func (*DLQMessage) GetTimestamp added in v0.3.4 

func (x *DLQMessage) GetTimestamp() string

func (*DLQMessage) GetTopic added in v0.3.4 

func (x *DLQMessage) GetTopic() string

func (*DLQMessage) GetValue added in v0.3.4 

func (x *DLQMessage) GetValue() string

func (*DLQMessage) ProtoMessage added in v0.3.4 

func (*DLQMessage) ProtoMessage()

func (*DLQMessage) ProtoReflect added in v0.3.4 

func (x *DLQMessage) ProtoReflect() protoreflect.Message

func (*DLQMessage) Reset added in v0.3.4 

func (x *DLQMessage) Reset()

func (*DLQMessage) String added in v0.3.4 

func (x *DLQMessage) String() string

type InfoResponse added in v0.3.4 

type InfoResponse struct {
	Skip map[string]*Topic `` /* 149-byte string literal not displayed */
	Dlq  *DLQMessage       `protobuf:"bytes,2,opt,name=dlq,proto3" json:"dlq,omitempty"`
	// contains filtered or unexported fields
}

func (*InfoResponse) Descriptor deprecated added in v0.3.4 

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

Deprecated: Use InfoResponse.ProtoReflect.Descriptor instead.

func (*InfoResponse) GetDlq added in v0.3.4 

func (x *InfoResponse) GetDlq() *DLQMessage

func (*InfoResponse) GetSkip added in v0.3.4 

func (x *InfoResponse) GetSkip() map[string]*Topic

func (*InfoResponse) ProtoMessage added in v0.3.4 

func (*InfoResponse) ProtoMessage()

func (*InfoResponse) ProtoReflect added in v0.3.4 

func (x *InfoResponse) ProtoReflect() protoreflect.Message

func (*InfoResponse) Reset added in v0.3.4 

func (x *InfoResponse) Reset()

func (*InfoResponse) String added in v0.3.4 

func (x *InfoResponse) String() string

type Partition 

type Partition struct {
	Offsets []int64 `protobuf:"varint,1,rep,packed,name=offsets,proto3" json:"offsets,omitempty"`
	Before  int64   `protobuf:"varint,2,opt,name=before,proto3" json:"before,omitempty"`
	// contains filtered or unexported fields
}

func (*Partition) Descriptor deprecated 

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

Deprecated: Use Partition.ProtoReflect.Descriptor instead.

func (*Partition) GetBefore 

func (x *Partition) GetBefore() int64

func (*Partition) GetOffsets 

func (x *Partition) GetOffsets() []int64

func (*Partition) ProtoMessage 

func (*Partition) ProtoMessage()

func (*Partition) ProtoReflect 

func (x *Partition) ProtoReflect() protoreflect.Message

func (*Partition) Reset 

func (x *Partition) Reset()

func (*Partition) String 

func (x *Partition) String() string

type Response 

type Response struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*Response) Descriptor deprecated 

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

Deprecated: Use Response.ProtoReflect.Descriptor instead.

func (*Response) GetMessage 

func (x *Response) GetMessage() string

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) ProtoReflect 

func (x *Response) ProtoReflect() protoreflect.Message

func (*Response) Reset 

func (x *Response) Reset()

func (*Response) String 

func (x *Response) String() string

type SkipOption 

type SkipOption int32
const (
	SkipOption_APPEND  SkipOption = 0
	SkipOption_REPLACE SkipOption = 1
)

func (SkipOption) Descriptor 

func (SkipOption) Descriptor() protoreflect.EnumDescriptor

func (SkipOption) Enum 

func (x SkipOption) Enum() *SkipOption

func (SkipOption) EnumDescriptor deprecated 

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

Deprecated: Use SkipOption.Descriptor instead.

func (SkipOption) Number 

func (x SkipOption) Number() protoreflect.EnumNumber

func (SkipOption) String 

func (x SkipOption) String() string

func (SkipOption) Type 

func (SkipOption) Type() protoreflect.EnumType

type Topic 

type Topic struct {
	Partitions map[int32]*Partition `` /* 162-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Topic) Descriptor deprecated 

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

Deprecated: Use Topic.ProtoReflect.Descriptor instead.

func (*Topic) GetPartitions 

func (x *Topic) GetPartitions() map[int32]*Partition

func (*Topic) ProtoMessage 

func (*Topic) ProtoMessage()

func (*Topic) ProtoReflect 

func (x *Topic) ProtoReflect() protoreflect.Message

func (*Topic) Reset 

func (x *Topic) Reset()

func (*Topic) String 

func (x *Topic) String() string

Source Files

View all Source files

Directories

Path Synopsis

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.