messages

package
v0.0.2 Latest Latest
Warning

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

 Go to latest Published: Aug 21, 2022 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_api_proto_consumer_proto protoreflect.FileDescriptor
View Source 
var File_api_proto_meta_proto protoreflect.FileDescriptor
View Source 
var File_api_proto_partition_proto protoreflect.FileDescriptor
View Source 
var File_api_proto_producer_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type ConsumerPayload 

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

func (*ConsumerPayload) Descriptor deprecated 

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

Deprecated: Use ConsumerPayload.ProtoReflect.Descriptor instead.

func (*ConsumerPayload) GetTopic 

func (x *ConsumerPayload) GetTopic() string

func (*ConsumerPayload) ProtoMessage 

func (*ConsumerPayload) ProtoMessage()

func (*ConsumerPayload) ProtoReflect 

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

func (*ConsumerPayload) Reset 

func (x *ConsumerPayload) Reset()

func (*ConsumerPayload) String 

func (x *ConsumerPayload) String() string

type ConsumerResponse 

type ConsumerResponse struct {
	IsEmpty bool   `protobuf:"varint,1,opt,name=isEmpty,proto3" json:"isEmpty,omitempty"`
	Message []byte `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*ConsumerResponse) Descriptor deprecated 

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

Deprecated: Use ConsumerResponse.ProtoReflect.Descriptor instead.

func (*ConsumerResponse) GetIsEmpty 

func (x *ConsumerResponse) GetIsEmpty() bool

func (*ConsumerResponse) GetMessage 

func (x *ConsumerResponse) GetMessage() []byte

func (*ConsumerResponse) ProtoMessage 

func (*ConsumerResponse) ProtoMessage()

func (*ConsumerResponse) ProtoReflect 

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

func (*ConsumerResponse) Reset 

func (x *ConsumerResponse) Reset()

func (*ConsumerResponse) String 

func (x *ConsumerResponse) String() string

type ErrorFormat 

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

func (*ErrorFormat) Descriptor deprecated 

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

Deprecated: Use ErrorFormat.ProtoReflect.Descriptor instead.

func (*ErrorFormat) GetMessage 

func (x *ErrorFormat) GetMessage() string

func (*ErrorFormat) ProtoMessage 

func (*ErrorFormat) ProtoMessage()

func (*ErrorFormat) ProtoReflect 

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

func (*ErrorFormat) Reset 

func (x *ErrorFormat) Reset()

func (*ErrorFormat) String 

func (x *ErrorFormat) String() string

type Partition 

type Partition struct {
	Topic   string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Message []byte `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*Partition) Descriptor deprecated 

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

Deprecated: Use Partition.ProtoReflect.Descriptor instead.

func (*Partition) GetMessage 

func (x *Partition) GetMessage() []byte

func (*Partition) GetTopic 

func (x *Partition) GetTopic() string

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 PartitionAsk 

type PartitionAsk struct {
	Ask bool `protobuf:"varint,1,opt,name=ask,proto3" json:"ask,omitempty"`
	// contains filtered or unexported fields
}

func (*PartitionAsk) Descriptor deprecated 

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

Deprecated: Use PartitionAsk.ProtoReflect.Descriptor instead.

func (*PartitionAsk) GetAsk 

func (x *PartitionAsk) GetAsk() bool

func (*PartitionAsk) ProtoMessage 

func (*PartitionAsk) ProtoMessage()

func (*PartitionAsk) ProtoReflect 

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

func (*PartitionAsk) Reset 

func (x *PartitionAsk) Reset()

func (*PartitionAsk) String 

func (x *PartitionAsk) String() string

type Ping 

type Ping struct {
	Ping int32 `protobuf:"varint,1,opt,name=ping,proto3" json:"ping,omitempty"`
	// contains filtered or unexported fields
}

func (*Ping) Descriptor deprecated 

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

Deprecated: Use Ping.ProtoReflect.Descriptor instead.

func (*Ping) GetPing 

func (x *Ping) GetPing() int32

func (*Ping) ProtoMessage 

func (*Ping) ProtoMessage()

func (*Ping) ProtoReflect 

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

func (*Ping) Reset 

func (x *Ping) Reset()

func (*Ping) String 

func (x *Ping) String() string

type Pong 

type Pong struct {
	Pong bool `protobuf:"varint,1,opt,name=pong,proto3" json:"pong,omitempty"`
	// contains filtered or unexported fields
}

func (*Pong) Descriptor deprecated 

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

Deprecated: Use Pong.ProtoReflect.Descriptor instead.

func (*Pong) GetPong 

func (x *Pong) GetPong() bool

func (*Pong) ProtoMessage 

func (*Pong) ProtoMessage()

func (*Pong) ProtoReflect 

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

func (*Pong) Reset 

func (x *Pong) Reset()

func (*Pong) String 

func (x *Pong) String() string

type ProducerAsk 

type ProducerAsk struct {
	Ask bool `protobuf:"varint,1,opt,name=ask,proto3" json:"ask,omitempty"`
	// contains filtered or unexported fields
}

func (*ProducerAsk) Descriptor deprecated 

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

Deprecated: Use ProducerAsk.ProtoReflect.Descriptor instead.

func (*ProducerAsk) GetAsk 

func (x *ProducerAsk) GetAsk() bool

func (*ProducerAsk) ProtoMessage 

func (*ProducerAsk) ProtoMessage()

func (*ProducerAsk) ProtoReflect 

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

func (*ProducerAsk) Reset 

func (x *ProducerAsk) Reset()

func (*ProducerAsk) String 

func (x *ProducerAsk) String() string

type ProducerPayload 

type ProducerPayload struct {
	Topic   string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Message []byte `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*ProducerPayload) Descriptor deprecated 

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

Deprecated: Use ProducerPayload.ProtoReflect.Descriptor instead.

func (*ProducerPayload) GetMessage 

func (x *ProducerPayload) GetMessage() []byte

func (*ProducerPayload) GetTopic 

func (x *ProducerPayload) GetTopic() string

func (*ProducerPayload) ProtoMessage 

func (*ProducerPayload) ProtoMessage()

func (*ProducerPayload) ProtoReflect 

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

func (*ProducerPayload) Reset 

func (x *ProducerPayload) Reset()

func (*ProducerPayload) String 

func (x *ProducerPayload) String() string

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.