kayakv1

package
v0.0.0-...-5aa5535 Latest Latest
Warning

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

 Go to latest Published: Jan 28, 2024 License: Apache-2.0 Imports: 25 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Hash_name = map[int32]string{
		0: "HASH_UNSPECIFIED",
		1: "HASH_MURMUR3",
	}
	Hash_value = map[string]int32{
		"HASH_UNSPECIFIED": 0,
		"HASH_MURMUR3":     1,
	}
)

Enum value maps for Hash.

View Source 
var File_proto_kayak_v1_kayak_proto protoreflect.FileDescriptor
View Source 
var KayakService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "kayak.v1.KayakService",
	HandlerType: (*KayakServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Apply",
			Handler:    _KayakService_Apply_Handler,
		},
		{
			MethodName: "PutRecords",
			Handler:    _KayakService_PutRecords_Handler,
		},
		{
			MethodName: "CommitRecord",
			Handler:    _KayakService_CommitRecord_Handler,
		},
		{
			MethodName: "CreateTopic",
			Handler:    _KayakService_CreateTopic_Handler,
		},
		{
			MethodName: "DeleteTopic",
			Handler:    _KayakService_DeleteTopic_Handler,
		},
		{
			MethodName: "RegisterConsumer",
			Handler:    _KayakService_RegisterConsumer_Handler,
		},
		{
			MethodName: "GetRecords",
			Handler:    _KayakService_GetRecords_Handler,
		},
		{
			MethodName: "FetchRecord",
			Handler:    _KayakService_FetchRecord_Handler,
		},
		{
			MethodName: "ListTopics",
			Handler:    _KayakService_ListTopics_Handler,
		},
		{
			MethodName: "Stats",
			Handler:    _KayakService_Stats_Handler,
		},
		{
			MethodName: "GetNodeDetails",
			Handler:    _KayakService_GetNodeDetails_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "StreamRecords",
			Handler:       _KayakService_StreamRecords_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "proto/kayak/v1/kayak.proto",
}

KayakService_ServiceDesc is the grpc.ServiceDesc for KayakService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterKayakServiceServer 

func RegisterKayakServiceServer(s grpc.ServiceRegistrar, srv KayakServiceServer)

Types

type ApplyResponse 

type ApplyResponse struct {
	Data *structpb.Value `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*ApplyResponse) Descriptor deprecated 

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

Deprecated: Use ApplyResponse.ProtoReflect.Descriptor instead.

func (*ApplyResponse) GetData 

func (x *ApplyResponse) GetData() *structpb.Value

func (*ApplyResponse) ProtoMessage 

func (*ApplyResponse) ProtoMessage()

func (*ApplyResponse) ProtoReflect 

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

func (*ApplyResponse) Reset 

func (x *ApplyResponse) Reset()

func (*ApplyResponse) String 

func (x *ApplyResponse) String() string

func (*ApplyResponse) Validate 

func (m *ApplyResponse) Validate() error

Validate checks the field values on ApplyResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ApplyResponse) ValidateAll 

func (m *ApplyResponse) ValidateAll() error

ValidateAll checks the field values on ApplyResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ApplyResponseMultiError, or nil if none found.

type ApplyResponseMultiError 

type ApplyResponseMultiError []error

ApplyResponseMultiError is an error wrapping multiple validation errors returned by ApplyResponse.ValidateAll() if the designated constraints aren't met.

func (ApplyResponseMultiError) AllErrors 

func (m ApplyResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ApplyResponseMultiError) Error 

func (m ApplyResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ApplyResponseValidationError 

type ApplyResponseValidationError struct {
	// contains filtered or unexported fields
}

ApplyResponseValidationError is the validation error returned by ApplyResponse.Validate if the designated constraints aren't met.

func (ApplyResponseValidationError) Cause 

func (e ApplyResponseValidationError) Cause() error

Cause function returns cause value.

func (ApplyResponseValidationError) Error 

func (e ApplyResponseValidationError) Error() string

Error satisfies the builtin error interface

func (ApplyResponseValidationError) ErrorName 

func (e ApplyResponseValidationError) ErrorName() string

ErrorName returns error name.

func (ApplyResponseValidationError) Field 

func (e ApplyResponseValidationError) Field() string

Field function returns field value.

func (ApplyResponseValidationError) Key 

func (e ApplyResponseValidationError) Key() bool

Key function returns key value.

func (ApplyResponseValidationError) Reason 

func (e ApplyResponseValidationError) Reason() string

Reason function returns reason value.

type Command 

type Command struct {

	// Types that are assignable to Payload:
	//	*Command_PutRecordsRequest
	//	*Command_CreateTopicRequest
	//	*Command_CommitRecordRequest
	//	*Command_DeleteTopicRequest
	//	*Command_CreateConsumerGroupRequest
	//	*Command_RegisterConsumerRequest
	Payload isCommand_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

func (*Command) Descriptor deprecated 

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

Deprecated: Use Command.ProtoReflect.Descriptor instead.

func (*Command) GetCommitRecordRequest 

func (x *Command) GetCommitRecordRequest() *CommitRecordRequest

func (*Command) GetCreateConsumerGroupRequest 

func (x *Command) GetCreateConsumerGroupRequest() *CreateConsumerGroupRequest

func (*Command) GetCreateTopicRequest 

func (x *Command) GetCreateTopicRequest() *CreateTopicRequest

func (*Command) GetDeleteTopicRequest 

func (x *Command) GetDeleteTopicRequest() *DeleteTopicRequest

func (*Command) GetPayload 

func (m *Command) GetPayload() isCommand_Payload

func (*Command) GetPutRecordsRequest 

func (x *Command) GetPutRecordsRequest() *PutRecordsRequest

func (*Command) GetRegisterConsumerRequest 

func (x *Command) GetRegisterConsumerRequest() *RegisterConsumerRequest

func (*Command) ProtoMessage 

func (*Command) ProtoMessage()

func (*Command) ProtoReflect 

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

func (*Command) Reset 

func (x *Command) Reset()

func (*Command) String 

func (x *Command) String() string

func (*Command) Validate 

func (m *Command) Validate() error

Validate checks the field values on Command with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Command) ValidateAll 

func (m *Command) ValidateAll() error

ValidateAll checks the field values on Command with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in CommandMultiError, or nil if none found.

type CommandMultiError 

type CommandMultiError []error

CommandMultiError is an error wrapping multiple validation errors returned by Command.ValidateAll() if the designated constraints aren't met.

func (CommandMultiError) AllErrors 

func (m CommandMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (CommandMultiError) Error 

func (m CommandMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type CommandValidationError 

type CommandValidationError struct {
	// contains filtered or unexported fields
}

CommandValidationError is the validation error returned by Command.Validate if the designated constraints aren't met.

func (CommandValidationError) Cause 

func (e CommandValidationError) Cause() error

Cause function returns cause value.

func (CommandValidationError) Error 

func (e CommandValidationError) Error() string

Error satisfies the builtin error interface

func (CommandValidationError) ErrorName 

func (e CommandValidationError) ErrorName() string

ErrorName returns error name.

func (CommandValidationError) Field 

func (e CommandValidationError) Field() string

Field function returns field value.

func (CommandValidationError) Key 

func (e CommandValidationError) Key() bool

Key function returns key value.

func (CommandValidationError) Reason 

func (e CommandValidationError) Reason() string

Reason function returns reason value.

type Command_CommitRecordRequest 

type Command_CommitRecordRequest struct {
	CommitRecordRequest *CommitRecordRequest `protobuf:"bytes,3,opt,name=commit_record_request,json=commitRecordRequest,proto3,oneof"`
}

type Command_CreateConsumerGroupRequest 

type Command_CreateConsumerGroupRequest struct {
	CreateConsumerGroupRequest *CreateConsumerGroupRequest `protobuf:"bytes,5,opt,name=create_consumer_group_request,json=createConsumerGroupRequest,proto3,oneof"`
}

type Command_CreateTopicRequest 

type Command_CreateTopicRequest struct {
	CreateTopicRequest *CreateTopicRequest `protobuf:"bytes,2,opt,name=create_topic_request,json=createTopicRequest,proto3,oneof"`
}

type Command_DeleteTopicRequest 

type Command_DeleteTopicRequest struct {
	DeleteTopicRequest *DeleteTopicRequest `protobuf:"bytes,4,opt,name=delete_topic_request,json=deleteTopicRequest,proto3,oneof"`
}

type Command_PutRecordsRequest 

type Command_PutRecordsRequest struct {
	PutRecordsRequest *PutRecordsRequest `protobuf:"bytes,1,opt,name=put_records_request,json=putRecordsRequest,proto3,oneof"`
}

type Command_RegisterConsumerRequest 

type Command_RegisterConsumerRequest struct {
	RegisterConsumerRequest *RegisterConsumerRequest `protobuf:"bytes,6,opt,name=register_consumer_request,json=registerConsumerRequest,proto3,oneof"`
}

type CommitRecordRequest 

type CommitRecordRequest struct {
	Consumer *TopicConsumer `protobuf:"bytes,1,opt,name=consumer,proto3" json:"consumer,omitempty"`
	// contains filtered or unexported fields
}

func (*CommitRecordRequest) Descriptor deprecated 

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

Deprecated: Use CommitRecordRequest.ProtoReflect.Descriptor instead.

func (*CommitRecordRequest) GetConsumer 

func (x *CommitRecordRequest) GetConsumer() *TopicConsumer

func (*CommitRecordRequest) ProtoMessage 

func (*CommitRecordRequest) ProtoMessage()

func (*CommitRecordRequest) ProtoReflect 

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

func (*CommitRecordRequest) Reset 

func (x *CommitRecordRequest) Reset()

func (*CommitRecordRequest) String 

func (x *CommitRecordRequest) String() string

func (*CommitRecordRequest) Validate 

func (m *CommitRecordRequest) Validate() error

Validate checks the field values on CommitRecordRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*CommitRecordRequest) ValidateAll 

func (m *CommitRecordRequest) ValidateAll() error

ValidateAll checks the field values on CommitRecordRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in CommitRecordRequestMultiError, or nil if none found.

type CommitRecordRequestMultiError 

type CommitRecordRequestMultiError []error

CommitRecordRequestMultiError is an error wrapping multiple validation errors returned by CommitRecordRequest.ValidateAll() if the designated constraints aren't met.

func (CommitRecordRequestMultiError) AllErrors 

func (m CommitRecordRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (CommitRecordRequestMultiError) Error 

func (m CommitRecordRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type CommitRecordRequestValidationError 

type CommitRecordRequestValidationError struct {
	// contains filtered or unexported fields
}

CommitRecordRequestValidationError is the validation error returned by CommitRecordRequest.Validate if the designated constraints aren't met.

func (CommitRecordRequestValidationError) Cause 

func (e CommitRecordRequestValidationError) Cause() error

Cause function returns cause value.

func (CommitRecordRequestValidationError) Error 

func (e CommitRecordRequestValidationError) Error() string

Error satisfies the builtin error interface

func (CommitRecordRequestValidationError) ErrorName 

func (e CommitRecordRequestValidationError) ErrorName() string

ErrorName returns error name.

func (CommitRecordRequestValidationError) Field 

func (e CommitRecordRequestValidationError) Field() string

Field function returns field value.

func (CommitRecordRequestValidationError) Key 

func (e CommitRecordRequestValidationError) Key() bool

Key function returns key value.

func (CommitRecordRequestValidationError) Reason 

func (e CommitRecordRequestValidationError) Reason() string

Reason function returns reason value.

type ConsumerGroup 

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

func (*ConsumerGroup) Descriptor deprecated 

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

Deprecated: Use ConsumerGroup.ProtoReflect.Descriptor instead.

func (*ConsumerGroup) GetName 

func (x *ConsumerGroup) GetName() string

func (*ConsumerGroup) GetTopic 

func (x *ConsumerGroup) GetTopic() string

func (*ConsumerGroup) ProtoMessage 

func (*ConsumerGroup) ProtoMessage()

func (*ConsumerGroup) ProtoReflect 

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

func (*ConsumerGroup) Reset 

func (x *ConsumerGroup) Reset()

func (*ConsumerGroup) String 

func (x *ConsumerGroup) String() string

func (*ConsumerGroup) Validate 

func (m *ConsumerGroup) Validate() error

Validate checks the field values on ConsumerGroup with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ConsumerGroup) ValidateAll 

func (m *ConsumerGroup) ValidateAll() error

ValidateAll checks the field values on ConsumerGroup with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ConsumerGroupMultiError, or nil if none found.

type ConsumerGroupMultiError 

type ConsumerGroupMultiError []error

ConsumerGroupMultiError is an error wrapping multiple validation errors returned by ConsumerGroup.ValidateAll() if the designated constraints aren't met.

func (ConsumerGroupMultiError) AllErrors 

func (m ConsumerGroupMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ConsumerGroupMultiError) Error 

func (m ConsumerGroupMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ConsumerGroupPartition 

type ConsumerGroupPartition struct {
	PartitionNumber int64  `protobuf:"varint,1,opt,name=partition_number,json=partitionNumber,proto3" json:"partition_number,omitempty"`
	ConsumerId      string `protobuf:"bytes,2,opt,name=consumer_id,json=consumerId,proto3" json:"consumer_id,omitempty"`
	Position        string `protobuf:"bytes,3,opt,name=position,proto3" json:"position,omitempty"`
	// contains filtered or unexported fields
}

func (*ConsumerGroupPartition) Descriptor deprecated 

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

Deprecated: Use ConsumerGroupPartition.ProtoReflect.Descriptor instead.

func (*ConsumerGroupPartition) GetConsumerId 

func (x *ConsumerGroupPartition) GetConsumerId() string

func (*ConsumerGroupPartition) GetPartitionNumber 

func (x *ConsumerGroupPartition) GetPartitionNumber() int64

func (*ConsumerGroupPartition) GetPosition 

func (x *ConsumerGroupPartition) GetPosition() string

func (*ConsumerGroupPartition) ProtoMessage 

func (*ConsumerGroupPartition) ProtoMessage()

func (*ConsumerGroupPartition) ProtoReflect 

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

func (*ConsumerGroupPartition) Reset 

func (x *ConsumerGroupPartition) Reset()

func (*ConsumerGroupPartition) String 

func (x *ConsumerGroupPartition) String() string

func (*ConsumerGroupPartition) Validate 

func (m *ConsumerGroupPartition) Validate() error

Validate checks the field values on ConsumerGroupPartition with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ConsumerGroupPartition) ValidateAll 

func (m *ConsumerGroupPartition) ValidateAll() error

ValidateAll checks the field values on ConsumerGroupPartition with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ConsumerGroupPartitionMultiError, or nil if none found.

type ConsumerGroupPartitionMultiError 

type ConsumerGroupPartitionMultiError []error

ConsumerGroupPartitionMultiError is an error wrapping multiple validation errors returned by ConsumerGroupPartition.ValidateAll() if the designated constraints aren't met.

func (ConsumerGroupPartitionMultiError) AllErrors 

func (m ConsumerGroupPartitionMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ConsumerGroupPartitionMultiError) Error 

func (m ConsumerGroupPartitionMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ConsumerGroupPartitionValidationError 

type ConsumerGroupPartitionValidationError struct {
	// contains filtered or unexported fields
}

ConsumerGroupPartitionValidationError is the validation error returned by ConsumerGroupPartition.Validate if the designated constraints aren't met.

func (ConsumerGroupPartitionValidationError) Cause 

func (e ConsumerGroupPartitionValidationError) Cause() error

Cause function returns cause value.

func (ConsumerGroupPartitionValidationError) Error 

func (e ConsumerGroupPartitionValidationError) Error() string

Error satisfies the builtin error interface

func (ConsumerGroupPartitionValidationError) ErrorName 

func (e ConsumerGroupPartitionValidationError) ErrorName() string

ErrorName returns error name.

func (ConsumerGroupPartitionValidationError) Field 

func (e ConsumerGroupPartitionValidationError) Field() string

Field function returns field value.

func (ConsumerGroupPartitionValidationError) Key 

func (e ConsumerGroupPartitionValidationError) Key() bool

Key function returns key value.

func (ConsumerGroupPartitionValidationError) Reason 

func (e ConsumerGroupPartitionValidationError) Reason() string

Reason function returns reason value.

type ConsumerGroupValidationError 

type ConsumerGroupValidationError struct {
	// contains filtered or unexported fields
}

ConsumerGroupValidationError is the validation error returned by ConsumerGroup.Validate if the designated constraints aren't met.

func (ConsumerGroupValidationError) Cause 

func (e ConsumerGroupValidationError) Cause() error

Cause function returns cause value.

func (ConsumerGroupValidationError) Error 

func (e ConsumerGroupValidationError) Error() string

Error satisfies the builtin error interface

func (ConsumerGroupValidationError) ErrorName 

func (e ConsumerGroupValidationError) ErrorName() string

ErrorName returns error name.

func (ConsumerGroupValidationError) Field 

func (e ConsumerGroupValidationError) Field() string

Field function returns field value.

func (ConsumerGroupValidationError) Key 

func (e ConsumerGroupValidationError) Key() bool

Key function returns key value.

func (ConsumerGroupValidationError) Reason 

func (e ConsumerGroupValidationError) Reason() string

Reason function returns reason value.

type CreateConsumerGroupRequest 

type CreateConsumerGroupRequest struct {
	Group *ConsumerGroup `protobuf:"bytes,1,opt,name=group,proto3" json:"group,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateConsumerGroupRequest) Descriptor deprecated 

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

Deprecated: Use CreateConsumerGroupRequest.ProtoReflect.Descriptor instead.

func (*CreateConsumerGroupRequest) GetGroup 

func (x *CreateConsumerGroupRequest) GetGroup() *ConsumerGroup

func (*CreateConsumerGroupRequest) ProtoMessage 

func (*CreateConsumerGroupRequest) ProtoMessage()

func (*CreateConsumerGroupRequest) ProtoReflect 

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

func (*CreateConsumerGroupRequest) Reset 

func (x *CreateConsumerGroupRequest) Reset()

func (*CreateConsumerGroupRequest) String 

func (x *CreateConsumerGroupRequest) String() string

func (*CreateConsumerGroupRequest) Validate 

func (m *CreateConsumerGroupRequest) Validate() error

Validate checks the field values on CreateConsumerGroupRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*CreateConsumerGroupRequest) ValidateAll 

func (m *CreateConsumerGroupRequest) ValidateAll() error

ValidateAll checks the field values on CreateConsumerGroupRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in CreateConsumerGroupRequestMultiError, or nil if none found.

type CreateConsumerGroupRequestMultiError 

type CreateConsumerGroupRequestMultiError []error

CreateConsumerGroupRequestMultiError is an error wrapping multiple validation errors returned by CreateConsumerGroupRequest.ValidateAll() if the designated constraints aren't met.

func (CreateConsumerGroupRequestMultiError) AllErrors 

func (m CreateConsumerGroupRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (CreateConsumerGroupRequestMultiError) Error 

func (m CreateConsumerGroupRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type CreateConsumerGroupRequestValidationError 

type CreateConsumerGroupRequestValidationError struct {
	// contains filtered or unexported fields
}

CreateConsumerGroupRequestValidationError is the validation error returned by CreateConsumerGroupRequest.Validate if the designated constraints aren't met.

func (CreateConsumerGroupRequestValidationError) Cause 

func (e CreateConsumerGroupRequestValidationError) Cause() error

Cause function returns cause value.

func (CreateConsumerGroupRequestValidationError) Error 

func (e CreateConsumerGroupRequestValidationError) Error() string

Error satisfies the builtin error interface

func (CreateConsumerGroupRequestValidationError) ErrorName 

func (e CreateConsumerGroupRequestValidationError) ErrorName() string

ErrorName returns error name.

func (CreateConsumerGroupRequestValidationError) Field 

func (e CreateConsumerGroupRequestValidationError) Field() string

Field function returns field value.

func (CreateConsumerGroupRequestValidationError) Key 

func (e CreateConsumerGroupRequestValidationError) Key() bool

Key function returns key value.

func (CreateConsumerGroupRequestValidationError) Reason 

func (e CreateConsumerGroupRequestValidationError) Reason() string

Reason function returns reason value.

type CreateTopicRequest 

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

func (*CreateTopicRequest) Descriptor deprecated 

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

Deprecated: Use CreateTopicRequest.ProtoReflect.Descriptor instead.

func (*CreateTopicRequest) GetTopic 

func (x *CreateTopicRequest) GetTopic() *Topic

func (*CreateTopicRequest) ProtoMessage 

func (*CreateTopicRequest) ProtoMessage()

func (*CreateTopicRequest) ProtoReflect 

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

func (*CreateTopicRequest) Reset 

func (x *CreateTopicRequest) Reset()

func (*CreateTopicRequest) String 

func (x *CreateTopicRequest) String() string

func (*CreateTopicRequest) Validate 

func (m *CreateTopicRequest) Validate() error

Validate checks the field values on CreateTopicRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*CreateTopicRequest) ValidateAll 

func (m *CreateTopicRequest) ValidateAll() error

ValidateAll checks the field values on CreateTopicRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in CreateTopicRequestMultiError, or nil if none found.

type CreateTopicRequestMultiError 

type CreateTopicRequestMultiError []error

CreateTopicRequestMultiError is an error wrapping multiple validation errors returned by CreateTopicRequest.ValidateAll() if the designated constraints aren't met.

func (CreateTopicRequestMultiError) AllErrors 

func (m CreateTopicRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (CreateTopicRequestMultiError) Error 

func (m CreateTopicRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type CreateTopicRequestValidationError 

type CreateTopicRequestValidationError struct {
	// contains filtered or unexported fields
}

CreateTopicRequestValidationError is the validation error returned by CreateTopicRequest.Validate if the designated constraints aren't met.

func (CreateTopicRequestValidationError) Cause 

func (e CreateTopicRequestValidationError) Cause() error

Cause function returns cause value.

func (CreateTopicRequestValidationError) Error 

func (e CreateTopicRequestValidationError) Error() string

Error satisfies the builtin error interface

func (CreateTopicRequestValidationError) ErrorName 

func (e CreateTopicRequestValidationError) ErrorName() string

ErrorName returns error name.

func (CreateTopicRequestValidationError) Field 

func (e CreateTopicRequestValidationError) Field() string

Field function returns field value.

func (CreateTopicRequestValidationError) Key 

func (e CreateTopicRequestValidationError) Key() bool

Key function returns key value.

func (CreateTopicRequestValidationError) Reason 

func (e CreateTopicRequestValidationError) Reason() string

Reason function returns reason value.

type DeleteTopicRequest 

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

func (*DeleteTopicRequest) Descriptor deprecated 

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

Deprecated: Use DeleteTopicRequest.ProtoReflect.Descriptor instead.

func (*DeleteTopicRequest) GetTopic 

func (x *DeleteTopicRequest) GetTopic() *Topic

func (*DeleteTopicRequest) ProtoMessage 

func (*DeleteTopicRequest) ProtoMessage()

func (*DeleteTopicRequest) ProtoReflect 

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

func (*DeleteTopicRequest) Reset 

func (x *DeleteTopicRequest) Reset()

func (*DeleteTopicRequest) String 

func (x *DeleteTopicRequest) String() string

func (*DeleteTopicRequest) Validate 

func (m *DeleteTopicRequest) Validate() error

Validate checks the field values on DeleteTopicRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*DeleteTopicRequest) ValidateAll 

func (m *DeleteTopicRequest) ValidateAll() error

ValidateAll checks the field values on DeleteTopicRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in DeleteTopicRequestMultiError, or nil if none found.

type DeleteTopicRequestMultiError 

type DeleteTopicRequestMultiError []error

DeleteTopicRequestMultiError is an error wrapping multiple validation errors returned by DeleteTopicRequest.ValidateAll() if the designated constraints aren't met.

func (DeleteTopicRequestMultiError) AllErrors 

func (m DeleteTopicRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DeleteTopicRequestMultiError) Error 

func (m DeleteTopicRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type DeleteTopicRequestValidationError 

type DeleteTopicRequestValidationError struct {
	// contains filtered or unexported fields
}

DeleteTopicRequestValidationError is the validation error returned by DeleteTopicRequest.Validate if the designated constraints aren't met.

func (DeleteTopicRequestValidationError) Cause 

func (e DeleteTopicRequestValidationError) Cause() error

Cause function returns cause value.

func (DeleteTopicRequestValidationError) Error 

func (e DeleteTopicRequestValidationError) Error() string

Error satisfies the builtin error interface

func (DeleteTopicRequestValidationError) ErrorName 

func (e DeleteTopicRequestValidationError) ErrorName() string

ErrorName returns error name.

func (DeleteTopicRequestValidationError) Field 

func (e DeleteTopicRequestValidationError) Field() string

Field function returns field value.

func (DeleteTopicRequestValidationError) Key 

func (e DeleteTopicRequestValidationError) Key() bool

Key function returns key value.

func (DeleteTopicRequestValidationError) Reason 

func (e DeleteTopicRequestValidationError) Reason() string

Reason function returns reason value.

type FetchRecordRequest 

type FetchRecordRequest struct {
	Consumer *TopicConsumer `protobuf:"bytes,1,opt,name=consumer,proto3" json:"consumer,omitempty"`
	// contains filtered or unexported fields
}

func (*FetchRecordRequest) Descriptor deprecated 

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

Deprecated: Use FetchRecordRequest.ProtoReflect.Descriptor instead.

func (*FetchRecordRequest) GetConsumer 

func (x *FetchRecordRequest) GetConsumer() *TopicConsumer

func (*FetchRecordRequest) ProtoMessage 

func (*FetchRecordRequest) ProtoMessage()

func (*FetchRecordRequest) ProtoReflect 

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

func (*FetchRecordRequest) Reset 

func (x *FetchRecordRequest) Reset()

func (*FetchRecordRequest) String 

func (x *FetchRecordRequest) String() string

func (*FetchRecordRequest) Validate 

func (m *FetchRecordRequest) Validate() error

Validate checks the field values on FetchRecordRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*FetchRecordRequest) ValidateAll 

func (m *FetchRecordRequest) ValidateAll() error

ValidateAll checks the field values on FetchRecordRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in FetchRecordRequestMultiError, or nil if none found.

type FetchRecordRequestMultiError 

type FetchRecordRequestMultiError []error

FetchRecordRequestMultiError is an error wrapping multiple validation errors returned by FetchRecordRequest.ValidateAll() if the designated constraints aren't met.

func (FetchRecordRequestMultiError) AllErrors 

func (m FetchRecordRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (FetchRecordRequestMultiError) Error 

func (m FetchRecordRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type FetchRecordRequestValidationError 

type FetchRecordRequestValidationError struct {
	// contains filtered or unexported fields
}

FetchRecordRequestValidationError is the validation error returned by FetchRecordRequest.Validate if the designated constraints aren't met.

func (FetchRecordRequestValidationError) Cause 

func (e FetchRecordRequestValidationError) Cause() error

Cause function returns cause value.

func (FetchRecordRequestValidationError) Error 

func (e FetchRecordRequestValidationError) Error() string

Error satisfies the builtin error interface

func (FetchRecordRequestValidationError) ErrorName 

func (e FetchRecordRequestValidationError) ErrorName() string

ErrorName returns error name.

func (FetchRecordRequestValidationError) Field 

func (e FetchRecordRequestValidationError) Field() string

Field function returns field value.

func (FetchRecordRequestValidationError) Key 

func (e FetchRecordRequestValidationError) Key() bool

Key function returns key value.

func (FetchRecordRequestValidationError) Reason 

func (e FetchRecordRequestValidationError) Reason() string

Reason function returns reason value.

type FetchRecordsResponse 

type FetchRecordsResponse struct {
	Record *Record `protobuf:"bytes,1,opt,name=record,proto3" json:"record,omitempty"`
	// contains filtered or unexported fields
}

func (*FetchRecordsResponse) Descriptor deprecated 

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

Deprecated: Use FetchRecordsResponse.ProtoReflect.Descriptor instead.

func (*FetchRecordsResponse) GetRecord 

func (x *FetchRecordsResponse) GetRecord() *Record

func (*FetchRecordsResponse) ProtoMessage 

func (*FetchRecordsResponse) ProtoMessage()

func (*FetchRecordsResponse) ProtoReflect 

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

func (*FetchRecordsResponse) Reset 

func (x *FetchRecordsResponse) Reset()

func (*FetchRecordsResponse) String 

func (x *FetchRecordsResponse) String() string

func (*FetchRecordsResponse) Validate 

func (m *FetchRecordsResponse) Validate() error

Validate checks the field values on FetchRecordsResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*FetchRecordsResponse) ValidateAll 

func (m *FetchRecordsResponse) ValidateAll() error

ValidateAll checks the field values on FetchRecordsResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in FetchRecordsResponseMultiError, or nil if none found.

type FetchRecordsResponseMultiError 

type FetchRecordsResponseMultiError []error

FetchRecordsResponseMultiError is an error wrapping multiple validation errors returned by FetchRecordsResponse.ValidateAll() if the designated constraints aren't met.

func (FetchRecordsResponseMultiError) AllErrors 

func (m FetchRecordsResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (FetchRecordsResponseMultiError) Error 

func (m FetchRecordsResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type FetchRecordsResponseValidationError 

type FetchRecordsResponseValidationError struct {
	// contains filtered or unexported fields
}

FetchRecordsResponseValidationError is the validation error returned by FetchRecordsResponse.Validate if the designated constraints aren't met.

func (FetchRecordsResponseValidationError) Cause 

func (e FetchRecordsResponseValidationError) Cause() error

Cause function returns cause value.

func (FetchRecordsResponseValidationError) Error 

func (e FetchRecordsResponseValidationError) Error() string

Error satisfies the builtin error interface

func (FetchRecordsResponseValidationError) ErrorName 

func (e FetchRecordsResponseValidationError) ErrorName() string

ErrorName returns error name.

func (FetchRecordsResponseValidationError) Field 

func (e FetchRecordsResponseValidationError) Field() string

Field function returns field value.

func (FetchRecordsResponseValidationError) Key 

func (e FetchRecordsResponseValidationError) Key() bool

Key function returns key value.

func (FetchRecordsResponseValidationError) Reason 

func (e FetchRecordsResponseValidationError) Reason() string

Reason function returns reason value.

type GetNodeDetailsResponse 

type GetNodeDetailsResponse struct {
	Id   string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Port int32  `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

func (*GetNodeDetailsResponse) Descriptor deprecated 

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

Deprecated: Use GetNodeDetailsResponse.ProtoReflect.Descriptor instead.

func (*GetNodeDetailsResponse) GetId 

func (x *GetNodeDetailsResponse) GetId() string

func (*GetNodeDetailsResponse) GetPort 

func (x *GetNodeDetailsResponse) GetPort() int32

func (*GetNodeDetailsResponse) ProtoMessage 

func (*GetNodeDetailsResponse) ProtoMessage()

func (*GetNodeDetailsResponse) ProtoReflect 

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

func (*GetNodeDetailsResponse) Reset 

func (x *GetNodeDetailsResponse) Reset()

func (*GetNodeDetailsResponse) String 

func (x *GetNodeDetailsResponse) String() string

func (*GetNodeDetailsResponse) Validate 

func (m *GetNodeDetailsResponse) Validate() error

Validate checks the field values on GetNodeDetailsResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*GetNodeDetailsResponse) ValidateAll 

func (m *GetNodeDetailsResponse) ValidateAll() error

ValidateAll checks the field values on GetNodeDetailsResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in GetNodeDetailsResponseMultiError, or nil if none found.

type GetNodeDetailsResponseMultiError 

type GetNodeDetailsResponseMultiError []error

GetNodeDetailsResponseMultiError is an error wrapping multiple validation errors returned by GetNodeDetailsResponse.ValidateAll() if the designated constraints aren't met.

func (GetNodeDetailsResponseMultiError) AllErrors 

func (m GetNodeDetailsResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (GetNodeDetailsResponseMultiError) Error 

func (m GetNodeDetailsResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type GetNodeDetailsResponseValidationError 

type GetNodeDetailsResponseValidationError struct {
	// contains filtered or unexported fields
}

GetNodeDetailsResponseValidationError is the validation error returned by GetNodeDetailsResponse.Validate if the designated constraints aren't met.

func (GetNodeDetailsResponseValidationError) Cause 

func (e GetNodeDetailsResponseValidationError) Cause() error

Cause function returns cause value.

func (GetNodeDetailsResponseValidationError) Error 

func (e GetNodeDetailsResponseValidationError) Error() string

Error satisfies the builtin error interface

func (GetNodeDetailsResponseValidationError) ErrorName 

func (e GetNodeDetailsResponseValidationError) ErrorName() string

ErrorName returns error name.

func (GetNodeDetailsResponseValidationError) Field 

func (e GetNodeDetailsResponseValidationError) Field() string

Field function returns field value.

func (GetNodeDetailsResponseValidationError) Key 

func (e GetNodeDetailsResponseValidationError) Key() bool

Key function returns key value.

func (GetNodeDetailsResponseValidationError) Reason 

func (e GetNodeDetailsResponseValidationError) Reason() string

Reason function returns reason value.

type GetRecordsRequest 

type GetRecordsRequest struct {
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Start string `protobuf:"bytes,2,opt,name=start,proto3" json:"start,omitempty"`
	Limit int64  `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRecordsRequest) Descriptor deprecated 

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

Deprecated: Use GetRecordsRequest.ProtoReflect.Descriptor instead.

func (*GetRecordsRequest) GetLimit 

func (x *GetRecordsRequest) GetLimit() int64

func (*GetRecordsRequest) GetStart 

func (x *GetRecordsRequest) GetStart() string

func (*GetRecordsRequest) GetTopic 

func (x *GetRecordsRequest) GetTopic() string

func (*GetRecordsRequest) ProtoMessage 

func (*GetRecordsRequest) ProtoMessage()

func (*GetRecordsRequest) ProtoReflect 

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

func (*GetRecordsRequest) Reset 

func (x *GetRecordsRequest) Reset()

func (*GetRecordsRequest) String 

func (x *GetRecordsRequest) String() string

func (*GetRecordsRequest) Validate 

func (m *GetRecordsRequest) Validate() error

Validate checks the field values on GetRecordsRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*GetRecordsRequest) ValidateAll 

func (m *GetRecordsRequest) ValidateAll() error

ValidateAll checks the field values on GetRecordsRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in GetRecordsRequestMultiError, or nil if none found.

type GetRecordsRequestMultiError 

type GetRecordsRequestMultiError []error

GetRecordsRequestMultiError is an error wrapping multiple validation errors returned by GetRecordsRequest.ValidateAll() if the designated constraints aren't met.

func (GetRecordsRequestMultiError) AllErrors 

func (m GetRecordsRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (GetRecordsRequestMultiError) Error 

func (m GetRecordsRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type GetRecordsRequestValidationError 

type GetRecordsRequestValidationError struct {
	// contains filtered or unexported fields
}

GetRecordsRequestValidationError is the validation error returned by GetRecordsRequest.Validate if the designated constraints aren't met.

func (GetRecordsRequestValidationError) Cause 

func (e GetRecordsRequestValidationError) Cause() error

Cause function returns cause value.

func (GetRecordsRequestValidationError) Error 

func (e GetRecordsRequestValidationError) Error() string

Error satisfies the builtin error interface

func (GetRecordsRequestValidationError) ErrorName 

func (e GetRecordsRequestValidationError) ErrorName() string

ErrorName returns error name.

func (GetRecordsRequestValidationError) Field 

func (e GetRecordsRequestValidationError) Field() string

Field function returns field value.

func (GetRecordsRequestValidationError) Key 

func (e GetRecordsRequestValidationError) Key() bool

Key function returns key value.

func (GetRecordsRequestValidationError) Reason 

func (e GetRecordsRequestValidationError) Reason() string

Reason function returns reason value.

type GetRecordsResponse 

type GetRecordsResponse struct {
	Records []*Record `protobuf:"bytes,1,rep,name=records,proto3" json:"records,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRecordsResponse) Descriptor deprecated 

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

Deprecated: Use GetRecordsResponse.ProtoReflect.Descriptor instead.

func (*GetRecordsResponse) GetRecords 

func (x *GetRecordsResponse) GetRecords() []*Record

func (*GetRecordsResponse) ProtoMessage 

func (*GetRecordsResponse) ProtoMessage()

func (*GetRecordsResponse) ProtoReflect 

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

func (*GetRecordsResponse) Reset 

func (x *GetRecordsResponse) Reset()

func (*GetRecordsResponse) String 

func (x *GetRecordsResponse) String() string

func (*GetRecordsResponse) Validate 

func (m *GetRecordsResponse) Validate() error

Validate checks the field values on GetRecordsResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*GetRecordsResponse) ValidateAll 

func (m *GetRecordsResponse) ValidateAll() error

ValidateAll checks the field values on GetRecordsResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in GetRecordsResponseMultiError, or nil if none found.

type GetRecordsResponseMultiError 

type GetRecordsResponseMultiError []error

GetRecordsResponseMultiError is an error wrapping multiple validation errors returned by GetRecordsResponse.ValidateAll() if the designated constraints aren't met.

func (GetRecordsResponseMultiError) AllErrors 

func (m GetRecordsResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (GetRecordsResponseMultiError) Error 

func (m GetRecordsResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type GetRecordsResponseValidationError 

type GetRecordsResponseValidationError struct {
	// contains filtered or unexported fields
}

GetRecordsResponseValidationError is the validation error returned by GetRecordsResponse.Validate if the designated constraints aren't met.

func (GetRecordsResponseValidationError) Cause 

func (e GetRecordsResponseValidationError) Cause() error

Cause function returns cause value.

func (GetRecordsResponseValidationError) Error 

func (e GetRecordsResponseValidationError) Error() string

Error satisfies the builtin error interface

func (GetRecordsResponseValidationError) ErrorName 

func (e GetRecordsResponseValidationError) ErrorName() string

ErrorName returns error name.

func (GetRecordsResponseValidationError) Field 

func (e GetRecordsResponseValidationError) Field() string

Field function returns field value.

func (GetRecordsResponseValidationError) Key 

func (e GetRecordsResponseValidationError) Key() bool

Key function returns key value.

func (GetRecordsResponseValidationError) Reason 

func (e GetRecordsResponseValidationError) Reason() string

Reason function returns reason value.

type GroupPartitions 

type GroupPartitions struct {
	Name       string           `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Partitions int64            `protobuf:"varint,2,opt,name=partitions,proto3" json:"partitions,omitempty"`
	Consumers  []*TopicConsumer `protobuf:"bytes,3,rep,name=consumers,proto3" json:"consumers,omitempty"`
	// contains filtered or unexported fields
}

func (*GroupPartitions) Descriptor deprecated 

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

Deprecated: Use GroupPartitions.ProtoReflect.Descriptor instead.

func (*GroupPartitions) GetConsumers 

func (x *GroupPartitions) GetConsumers() []*TopicConsumer

func (*GroupPartitions) GetName 

func (x *GroupPartitions) GetName() string

func (*GroupPartitions) GetPartitions 

func (x *GroupPartitions) GetPartitions() int64

func (*GroupPartitions) ProtoMessage 

func (*GroupPartitions) ProtoMessage()

func (*GroupPartitions) ProtoReflect 

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

func (*GroupPartitions) Reset 

func (x *GroupPartitions) Reset()

func (*GroupPartitions) String 

func (x *GroupPartitions) String() string

func (*GroupPartitions) Validate 

func (m *GroupPartitions) Validate() error

Validate checks the field values on GroupPartitions with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*GroupPartitions) ValidateAll 

func (m *GroupPartitions) ValidateAll() error

ValidateAll checks the field values on GroupPartitions with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in GroupPartitionsMultiError, or nil if none found.

type GroupPartitionsMultiError 

type GroupPartitionsMultiError []error

GroupPartitionsMultiError is an error wrapping multiple validation errors returned by GroupPartitions.ValidateAll() if the designated constraints aren't met.

func (GroupPartitionsMultiError) AllErrors 

func (m GroupPartitionsMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (GroupPartitionsMultiError) Error 

func (m GroupPartitionsMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type GroupPartitionsValidationError 

type GroupPartitionsValidationError struct {
	// contains filtered or unexported fields
}

GroupPartitionsValidationError is the validation error returned by GroupPartitions.Validate if the designated constraints aren't met.

func (GroupPartitionsValidationError) Cause 

func (e GroupPartitionsValidationError) Cause() error

Cause function returns cause value.

func (GroupPartitionsValidationError) Error 

func (e GroupPartitionsValidationError) Error() string

Error satisfies the builtin error interface

func (GroupPartitionsValidationError) ErrorName 

func (e GroupPartitionsValidationError) ErrorName() string

ErrorName returns error name.

func (GroupPartitionsValidationError) Field 

func (e GroupPartitionsValidationError) Field() string

Field function returns field value.

func (GroupPartitionsValidationError) Key 

func (e GroupPartitionsValidationError) Key() bool

Key function returns key value.

func (GroupPartitionsValidationError) Reason 

func (e GroupPartitionsValidationError) Reason() string

Reason function returns reason value.

type Hash 

type Hash int32
const (
	Hash_HASH_UNSPECIFIED Hash = 0
	Hash_HASH_MURMUR3     Hash = 1
)

func (Hash) Descriptor 

func (Hash) Descriptor() protoreflect.EnumDescriptor

func (Hash) Enum 

func (x Hash) Enum() *Hash

func (Hash) EnumDescriptor deprecated 

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

Deprecated: Use Hash.Descriptor instead.

func (Hash) Number 

func (x Hash) Number() protoreflect.EnumNumber

func (Hash) String 

func (x Hash) String() string

func (Hash) Type 

func (Hash) Type() protoreflect.EnumType

type KVItem 

type KVItem struct {
	Key    []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value  []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Bucket []byte `protobuf:"bytes,3,opt,name=bucket,proto3" json:"bucket,omitempty"`
	// contains filtered or unexported fields
}

func (*KVItem) Descriptor deprecated 

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

Deprecated: Use KVItem.ProtoReflect.Descriptor instead.

func (*KVItem) GetBucket 

func (x *KVItem) GetBucket() []byte

func (*KVItem) GetKey 

func (x *KVItem) GetKey() []byte

func (*KVItem) GetValue 

func (x *KVItem) GetValue() []byte

func (*KVItem) ProtoMessage 

func (*KVItem) ProtoMessage()

func (*KVItem) ProtoReflect 

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

func (*KVItem) Reset 

func (x *KVItem) Reset()

func (*KVItem) String 

func (x *KVItem) String() string

func (*KVItem) Validate 

func (m *KVItem) Validate() error

Validate checks the field values on KVItem with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*KVItem) ValidateAll 

func (m *KVItem) ValidateAll() error

ValidateAll checks the field values on KVItem with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in KVItemMultiError, or nil if none found.

type KVItemMultiError 

type KVItemMultiError []error

KVItemMultiError is an error wrapping multiple validation errors returned by KVItem.ValidateAll() if the designated constraints aren't met.

func (KVItemMultiError) AllErrors 

func (m KVItemMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (KVItemMultiError) Error 

func (m KVItemMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type KVItemValidationError 

type KVItemValidationError struct {
	// contains filtered or unexported fields
}

KVItemValidationError is the validation error returned by KVItem.Validate if the designated constraints aren't met.

func (KVItemValidationError) Cause 

func (e KVItemValidationError) Cause() error

Cause function returns cause value.

func (KVItemValidationError) Error 

func (e KVItemValidationError) Error() string

Error satisfies the builtin error interface

func (KVItemValidationError) ErrorName 

func (e KVItemValidationError) ErrorName() string

ErrorName returns error name.

func (KVItemValidationError) Field 

func (e KVItemValidationError) Field() string

Field function returns field value.

func (KVItemValidationError) Key 

func (e KVItemValidationError) Key() bool

Key function returns key value.

func (KVItemValidationError) Reason 

func (e KVItemValidationError) Reason() string

Reason function returns reason value.

type KayakServiceClient 

type KayakServiceClient interface {
	// Apply applies a command on the primary node.
	Apply(ctx context.Context, in *Command, opts ...grpc.CallOption) (*ApplyResponse, error)
	// PutRecords adds records to the stream
	PutRecords(ctx context.Context, in *PutRecordsRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Commits Consumer position for a topic/group
	CommitRecord(ctx context.Context, in *CommitRecordRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Creates new topic on server
	CreateTopic(ctx context.Context, in *CreateTopicRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Deletes Topic across server - permantly or via archive
	DeleteTopic(ctx context.Context, in *DeleteTopicRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// rpc CreateConsumerGroup(CreateConsumerGroupRequest) returns (google.protobuf.Empty) {}
	RegisterConsumer(ctx context.Context, in *RegisterConsumerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Read Procedures
	GetRecords(ctx context.Context, in *GetRecordsRequest, opts ...grpc.CallOption) (*GetRecordsResponse, error)
	FetchRecord(ctx context.Context, in *FetchRecordRequest, opts ...grpc.CallOption) (*FetchRecordsResponse, error)
	StreamRecords(ctx context.Context, in *StreamRecordsRequest, opts ...grpc.CallOption) (KayakService_StreamRecordsClient, error)
	ListTopics(ctx context.Context, in *ListTopicsRequest, opts ...grpc.CallOption) (*ListTopicsResponse, error)
	Stats(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*StatsResponse, error)
	GetNodeDetails(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetNodeDetailsResponse, error)
}

KayakServiceClient is the client API for KayakService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewKayakServiceClient 

func NewKayakServiceClient(cc grpc.ClientConnInterface) KayakServiceClient

type KayakServiceServer 

type KayakServiceServer interface {
	// Apply applies a command on the primary node.
	Apply(context.Context, *Command) (*ApplyResponse, error)
	// PutRecords adds records to the stream
	PutRecords(context.Context, *PutRecordsRequest) (*emptypb.Empty, error)
	// Commits Consumer position for a topic/group
	CommitRecord(context.Context, *CommitRecordRequest) (*emptypb.Empty, error)
	// Creates new topic on server
	CreateTopic(context.Context, *CreateTopicRequest) (*emptypb.Empty, error)
	// Deletes Topic across server - permantly or via archive
	DeleteTopic(context.Context, *DeleteTopicRequest) (*emptypb.Empty, error)
	// rpc CreateConsumerGroup(CreateConsumerGroupRequest) returns (google.protobuf.Empty) {}
	RegisterConsumer(context.Context, *RegisterConsumerRequest) (*emptypb.Empty, error)
	// Read Procedures
	GetRecords(context.Context, *GetRecordsRequest) (*GetRecordsResponse, error)
	FetchRecord(context.Context, *FetchRecordRequest) (*FetchRecordsResponse, error)
	StreamRecords(*StreamRecordsRequest, KayakService_StreamRecordsServer) error
	ListTopics(context.Context, *ListTopicsRequest) (*ListTopicsResponse, error)
	Stats(context.Context, *emptypb.Empty) (*StatsResponse, error)
	GetNodeDetails(context.Context, *emptypb.Empty) (*GetNodeDetailsResponse, error)
}

KayakServiceServer is the server API for KayakService service. All implementations should embed UnimplementedKayakServiceServer for forward compatibility

type KayakService_StreamRecordsClient 

type KayakService_StreamRecordsClient interface {
	Recv() (*Record, error)
	grpc.ClientStream
}

type KayakService_StreamRecordsServer 

type KayakService_StreamRecordsServer interface {
	Send(*Record) error
	grpc.ServerStream
}

type ListTopicsRequest 

type ListTopicsRequest struct {
	// contains filtered or unexported fields
}

func (*ListTopicsRequest) Descriptor deprecated 

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

Deprecated: Use ListTopicsRequest.ProtoReflect.Descriptor instead.

func (*ListTopicsRequest) ProtoMessage 

func (*ListTopicsRequest) ProtoMessage()

func (*ListTopicsRequest) ProtoReflect 

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

func (*ListTopicsRequest) Reset 

func (x *ListTopicsRequest) Reset()

func (*ListTopicsRequest) String 

func (x *ListTopicsRequest) String() string

func (*ListTopicsRequest) Validate 

func (m *ListTopicsRequest) Validate() error

Validate checks the field values on ListTopicsRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ListTopicsRequest) ValidateAll 

func (m *ListTopicsRequest) ValidateAll() error

ValidateAll checks the field values on ListTopicsRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ListTopicsRequestMultiError, or nil if none found.

type ListTopicsRequestMultiError 

type ListTopicsRequestMultiError []error

ListTopicsRequestMultiError is an error wrapping multiple validation errors returned by ListTopicsRequest.ValidateAll() if the designated constraints aren't met.

func (ListTopicsRequestMultiError) AllErrors 

func (m ListTopicsRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ListTopicsRequestMultiError) Error 

func (m ListTopicsRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ListTopicsRequestValidationError 

type ListTopicsRequestValidationError struct {
	// contains filtered or unexported fields
}

ListTopicsRequestValidationError is the validation error returned by ListTopicsRequest.Validate if the designated constraints aren't met.

func (ListTopicsRequestValidationError) Cause 

func (e ListTopicsRequestValidationError) Cause() error

Cause function returns cause value.

func (ListTopicsRequestValidationError) Error 

func (e ListTopicsRequestValidationError) Error() string

Error satisfies the builtin error interface

func (ListTopicsRequestValidationError) ErrorName 

func (e ListTopicsRequestValidationError) ErrorName() string

ErrorName returns error name.

func (ListTopicsRequestValidationError) Field 

func (e ListTopicsRequestValidationError) Field() string

Field function returns field value.

func (ListTopicsRequestValidationError) Key 

func (e ListTopicsRequestValidationError) Key() bool

Key function returns key value.

func (ListTopicsRequestValidationError) Reason 

func (e ListTopicsRequestValidationError) Reason() string

Reason function returns reason value.

type ListTopicsResponse 

type ListTopicsResponse struct {
	Topics []*Topic `protobuf:"bytes,1,rep,name=topics,proto3" json:"topics,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTopicsResponse) Descriptor deprecated 

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

Deprecated: Use ListTopicsResponse.ProtoReflect.Descriptor instead.

func (*ListTopicsResponse) GetTopics 

func (x *ListTopicsResponse) GetTopics() []*Topic

func (*ListTopicsResponse) ProtoMessage 

func (*ListTopicsResponse) ProtoMessage()

func (*ListTopicsResponse) ProtoReflect 

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

func (*ListTopicsResponse) Reset 

func (x *ListTopicsResponse) Reset()

func (*ListTopicsResponse) String 

func (x *ListTopicsResponse) String() string

func (*ListTopicsResponse) Validate 

func (m *ListTopicsResponse) Validate() error

Validate checks the field values on ListTopicsResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ListTopicsResponse) ValidateAll 

func (m *ListTopicsResponse) ValidateAll() error

ValidateAll checks the field values on ListTopicsResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ListTopicsResponseMultiError, or nil if none found.

type ListTopicsResponseMultiError 

type ListTopicsResponseMultiError []error

ListTopicsResponseMultiError is an error wrapping multiple validation errors returned by ListTopicsResponse.ValidateAll() if the designated constraints aren't met.

func (ListTopicsResponseMultiError) AllErrors 

func (m ListTopicsResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ListTopicsResponseMultiError) Error 

func (m ListTopicsResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ListTopicsResponseValidationError 

type ListTopicsResponseValidationError struct {
	// contains filtered or unexported fields
}

ListTopicsResponseValidationError is the validation error returned by ListTopicsResponse.Validate if the designated constraints aren't met.

func (ListTopicsResponseValidationError) Cause 

func (e ListTopicsResponseValidationError) Cause() error

Cause function returns cause value.

func (ListTopicsResponseValidationError) Error 

func (e ListTopicsResponseValidationError) Error() string

Error satisfies the builtin error interface

func (ListTopicsResponseValidationError) ErrorName 

func (e ListTopicsResponseValidationError) ErrorName() string

ErrorName returns error name.

func (ListTopicsResponseValidationError) Field 

func (e ListTopicsResponseValidationError) Field() string

Field function returns field value.

func (ListTopicsResponseValidationError) Key 

func (e ListTopicsResponseValidationError) Key() bool

Key function returns key value.

func (ListTopicsResponseValidationError) Reason 

func (e ListTopicsResponseValidationError) Reason() string

Reason function returns reason value.

type PutRecordsRequest 

type PutRecordsRequest struct {
	Topic          string    `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Records        []*Record `protobuf:"bytes,2,rep,name=records,proto3" json:"records,omitempty"`
	IdempotencyKey string    `protobuf:"bytes,3,opt,name=idempotency_key,json=idempotencyKey,proto3" json:"idempotency_key,omitempty"`
	// contains filtered or unexported fields
}

func (*PutRecordsRequest) Descriptor deprecated 

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

Deprecated: Use PutRecordsRequest.ProtoReflect.Descriptor instead.

func (*PutRecordsRequest) GetIdempotencyKey 

func (x *PutRecordsRequest) GetIdempotencyKey() string

func (*PutRecordsRequest) GetRecords 

func (x *PutRecordsRequest) GetRecords() []*Record

func (*PutRecordsRequest) GetTopic 

func (x *PutRecordsRequest) GetTopic() string

func (*PutRecordsRequest) ProtoMessage 

func (*PutRecordsRequest) ProtoMessage()

func (*PutRecordsRequest) ProtoReflect 

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

func (*PutRecordsRequest) Reset 

func (x *PutRecordsRequest) Reset()

func (*PutRecordsRequest) String 

func (x *PutRecordsRequest) String() string

func (*PutRecordsRequest) Validate 

func (m *PutRecordsRequest) Validate() error

Validate checks the field values on PutRecordsRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*PutRecordsRequest) ValidateAll 

func (m *PutRecordsRequest) ValidateAll() error

ValidateAll checks the field values on PutRecordsRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in PutRecordsRequestMultiError, or nil if none found.

type PutRecordsRequestMultiError 

type PutRecordsRequestMultiError []error

PutRecordsRequestMultiError is an error wrapping multiple validation errors returned by PutRecordsRequest.ValidateAll() if the designated constraints aren't met.

func (PutRecordsRequestMultiError) AllErrors 

func (m PutRecordsRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PutRecordsRequestMultiError) Error 

func (m PutRecordsRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type PutRecordsRequestValidationError 

type PutRecordsRequestValidationError struct {
	// contains filtered or unexported fields
}

PutRecordsRequestValidationError is the validation error returned by PutRecordsRequest.Validate if the designated constraints aren't met.

func (PutRecordsRequestValidationError) Cause 

func (e PutRecordsRequestValidationError) Cause() error

Cause function returns cause value.

func (PutRecordsRequestValidationError) Error 

func (e PutRecordsRequestValidationError) Error() string

Error satisfies the builtin error interface

func (PutRecordsRequestValidationError) ErrorName 

func (e PutRecordsRequestValidationError) ErrorName() string

ErrorName returns error name.

func (PutRecordsRequestValidationError) Field 

func (e PutRecordsRequestValidationError) Field() string

Field function returns field value.

func (PutRecordsRequestValidationError) Key 

func (e PutRecordsRequestValidationError) Key() bool

Key function returns key value.

func (PutRecordsRequestValidationError) Reason 

func (e PutRecordsRequestValidationError) Reason() string

Reason function returns reason value.

type Record 

type Record struct {
	Topic     string            `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Partition int64             `protobuf:"varint,2,opt,name=partition,proto3" json:"partition,omitempty"`
	Id        string            `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`
	Headers   map[string]string `` /* 155-byte string literal not displayed */
	Payload   []byte            `protobuf:"bytes,5,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*Record) Descriptor deprecated 

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

Deprecated: Use Record.ProtoReflect.Descriptor instead.

func (*Record) GetHeaders 

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

func (*Record) GetId 

func (x *Record) GetId() string

func (*Record) GetPartition 

func (x *Record) GetPartition() int64

func (*Record) GetPayload 

func (x *Record) GetPayload() []byte

func (*Record) GetTopic 

func (x *Record) GetTopic() string

func (*Record) ProtoMessage 

func (*Record) ProtoMessage()

func (*Record) ProtoReflect 

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

func (*Record) Reset 

func (x *Record) Reset()

func (*Record) String 

func (x *Record) String() string

func (*Record) Validate 

func (m *Record) Validate() error

Validate checks the field values on Record with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Record) ValidateAll 

func (m *Record) ValidateAll() error

ValidateAll checks the field values on Record with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in RecordMultiError, or nil if none found.

type RecordMultiError 

type RecordMultiError []error

RecordMultiError is an error wrapping multiple validation errors returned by Record.ValidateAll() if the designated constraints aren't met.

func (RecordMultiError) AllErrors 

func (m RecordMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (RecordMultiError) Error 

func (m RecordMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type RecordValidationError 

type RecordValidationError struct {
	// contains filtered or unexported fields
}

RecordValidationError is the validation error returned by Record.Validate if the designated constraints aren't met.

func (RecordValidationError) Cause 

func (e RecordValidationError) Cause() error

Cause function returns cause value.

func (RecordValidationError) Error 

func (e RecordValidationError) Error() string

Error satisfies the builtin error interface

func (RecordValidationError) ErrorName 

func (e RecordValidationError) ErrorName() string

ErrorName returns error name.

func (RecordValidationError) Field 

func (e RecordValidationError) Field() string

Field function returns field value.

func (RecordValidationError) Key 

func (e RecordValidationError) Key() bool

Key function returns key value.

func (RecordValidationError) Reason 

func (e RecordValidationError) Reason() string

Reason function returns reason value.

type RegisterConsumerRequest 

type RegisterConsumerRequest struct {
	Consumer *TopicConsumer `protobuf:"bytes,1,opt,name=consumer,proto3" json:"consumer,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterConsumerRequest) Descriptor deprecated 

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

Deprecated: Use RegisterConsumerRequest.ProtoReflect.Descriptor instead.

func (*RegisterConsumerRequest) GetConsumer 

func (x *RegisterConsumerRequest) GetConsumer() *TopicConsumer

func (*RegisterConsumerRequest) ProtoMessage 

func (*RegisterConsumerRequest) ProtoMessage()

func (*RegisterConsumerRequest) ProtoReflect 

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

func (*RegisterConsumerRequest) Reset 

func (x *RegisterConsumerRequest) Reset()

func (*RegisterConsumerRequest) String 

func (x *RegisterConsumerRequest) String() string

func (*RegisterConsumerRequest) Validate 

func (m *RegisterConsumerRequest) Validate() error

Validate checks the field values on RegisterConsumerRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*RegisterConsumerRequest) ValidateAll 

func (m *RegisterConsumerRequest) ValidateAll() error

ValidateAll checks the field values on RegisterConsumerRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in RegisterConsumerRequestMultiError, or nil if none found.

type RegisterConsumerRequestMultiError 

type RegisterConsumerRequestMultiError []error

RegisterConsumerRequestMultiError is an error wrapping multiple validation errors returned by RegisterConsumerRequest.ValidateAll() if the designated constraints aren't met.

func (RegisterConsumerRequestMultiError) AllErrors 

func (m RegisterConsumerRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (RegisterConsumerRequestMultiError) Error 

func (m RegisterConsumerRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type RegisterConsumerRequestValidationError 

type RegisterConsumerRequestValidationError struct {
	// contains filtered or unexported fields
}

RegisterConsumerRequestValidationError is the validation error returned by RegisterConsumerRequest.Validate if the designated constraints aren't met.

func (RegisterConsumerRequestValidationError) Cause 

func (e RegisterConsumerRequestValidationError) Cause() error

Cause function returns cause value.

func (RegisterConsumerRequestValidationError) Error 

func (e RegisterConsumerRequestValidationError) Error() string

Error satisfies the builtin error interface

func (RegisterConsumerRequestValidationError) ErrorName 

func (e RegisterConsumerRequestValidationError) ErrorName() string

ErrorName returns error name.

func (RegisterConsumerRequestValidationError) Field 

func (e RegisterConsumerRequestValidationError) Field() string

Field function returns field value.

func (RegisterConsumerRequestValidationError) Key 

func (e RegisterConsumerRequestValidationError) Key() bool

Key function returns key value.

func (RegisterConsumerRequestValidationError) Reason 

func (e RegisterConsumerRequestValidationError) Reason() string

Reason function returns reason value.

type StatsResponse 

type StatsResponse struct {
	Raft  map[string]string         `` /* 149-byte string literal not displayed */
	Store map[string]*TopicMetadata `` /* 151-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*StatsResponse) Descriptor deprecated 

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

Deprecated: Use StatsResponse.ProtoReflect.Descriptor instead.

func (*StatsResponse) GetRaft 

func (x *StatsResponse) GetRaft() map[string]string

func (*StatsResponse) GetStore 

func (x *StatsResponse) GetStore() map[string]*TopicMetadata

func (*StatsResponse) ProtoMessage 

func (*StatsResponse) ProtoMessage()

func (*StatsResponse) ProtoReflect 

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

func (*StatsResponse) Reset 

func (x *StatsResponse) Reset()

func (*StatsResponse) String 

func (x *StatsResponse) String() string

func (*StatsResponse) Validate 

func (m *StatsResponse) Validate() error

Validate checks the field values on StatsResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*StatsResponse) ValidateAll 

func (m *StatsResponse) ValidateAll() error

ValidateAll checks the field values on StatsResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in StatsResponseMultiError, or nil if none found.

type StatsResponseMultiError 

type StatsResponseMultiError []error

StatsResponseMultiError is an error wrapping multiple validation errors returned by StatsResponse.ValidateAll() if the designated constraints aren't met.

func (StatsResponseMultiError) AllErrors 

func (m StatsResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (StatsResponseMultiError) Error 

func (m StatsResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type StatsResponseValidationError 

type StatsResponseValidationError struct {
	// contains filtered or unexported fields
}

StatsResponseValidationError is the validation error returned by StatsResponse.Validate if the designated constraints aren't met.

func (StatsResponseValidationError) Cause 

func (e StatsResponseValidationError) Cause() error

Cause function returns cause value.

func (StatsResponseValidationError) Error 

func (e StatsResponseValidationError) Error() string

Error satisfies the builtin error interface

func (StatsResponseValidationError) ErrorName 

func (e StatsResponseValidationError) ErrorName() string

ErrorName returns error name.

func (StatsResponseValidationError) Field 

func (e StatsResponseValidationError) Field() string

Field function returns field value.

func (StatsResponseValidationError) Key 

func (e StatsResponseValidationError) Key() bool

Key function returns key value.

func (StatsResponseValidationError) Reason 

func (e StatsResponseValidationError) Reason() string

Reason function returns reason value.

type StreamRecordsRequest 

type StreamRecordsRequest struct {

	// topic is the topic to get records from
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// position is where in the stream to start consuming.
	Position string `protobuf:"bytes,2,opt,name=position,proto3" json:"position,omitempty"`
	// batch_size indicates how many records to pull at once. If a value of 0 is given, service defaults to 1.
	BatchSize int32 `protobuf:"varint,3,opt,name=batch_size,json=batchSize,proto3" json:"batch_size,omitempty"`
	// timeout is when the server should return if no new records are found.
	Timeout *durationpb.Duration `protobuf:"bytes,4,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamRecordsRequest) Descriptor deprecated 

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

Deprecated: Use StreamRecordsRequest.ProtoReflect.Descriptor instead.

func (*StreamRecordsRequest) GetBatchSize 

func (x *StreamRecordsRequest) GetBatchSize() int32

func (*StreamRecordsRequest) GetPosition 

func (x *StreamRecordsRequest) GetPosition() string

func (*StreamRecordsRequest) GetTimeout 

func (x *StreamRecordsRequest) GetTimeout() *durationpb.Duration

func (*StreamRecordsRequest) GetTopic 

func (x *StreamRecordsRequest) GetTopic() string

func (*StreamRecordsRequest) ProtoMessage 

func (*StreamRecordsRequest) ProtoMessage()

func (*StreamRecordsRequest) ProtoReflect 

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

func (*StreamRecordsRequest) Reset 

func (x *StreamRecordsRequest) Reset()

func (*StreamRecordsRequest) String 

func (x *StreamRecordsRequest) String() string

func (*StreamRecordsRequest) Validate 

func (m *StreamRecordsRequest) Validate() error

Validate checks the field values on StreamRecordsRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*StreamRecordsRequest) ValidateAll 

func (m *StreamRecordsRequest) ValidateAll() error

ValidateAll checks the field values on StreamRecordsRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in StreamRecordsRequestMultiError, or nil if none found.

type StreamRecordsRequestMultiError 

type StreamRecordsRequestMultiError []error

StreamRecordsRequestMultiError is an error wrapping multiple validation errors returned by StreamRecordsRequest.ValidateAll() if the designated constraints aren't met.

func (StreamRecordsRequestMultiError) AllErrors 

func (m StreamRecordsRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (StreamRecordsRequestMultiError) Error 

func (m StreamRecordsRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type StreamRecordsRequestValidationError 

type StreamRecordsRequestValidationError struct {
	// contains filtered or unexported fields
}

StreamRecordsRequestValidationError is the validation error returned by StreamRecordsRequest.Validate if the designated constraints aren't met.

func (StreamRecordsRequestValidationError) Cause 

func (e StreamRecordsRequestValidationError) Cause() error

Cause function returns cause value.

func (StreamRecordsRequestValidationError) Error 

func (e StreamRecordsRequestValidationError) Error() string

Error satisfies the builtin error interface

func (StreamRecordsRequestValidationError) ErrorName 

func (e StreamRecordsRequestValidationError) ErrorName() string

ErrorName returns error name.

func (StreamRecordsRequestValidationError) Field 

func (e StreamRecordsRequestValidationError) Field() string

Field function returns field value.

func (StreamRecordsRequestValidationError) Key 

func (e StreamRecordsRequestValidationError) Key() bool

Key function returns key value.

func (StreamRecordsRequestValidationError) Reason 

func (e StreamRecordsRequestValidationError) Reason() string

Reason function returns reason value.

type Topic 

type Topic struct {
	Name       string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Partitions int64  `protobuf:"varint,2,opt,name=partitions,proto3" json:"partitions,omitempty"`
	Archived   bool   `protobuf:"varint,3,opt,name=archived,proto3" json:"archived,omitempty"`
	Ttl        int64  `protobuf:"varint,4,opt,name=ttl,proto3" json:"ttl,omitempty"` // max age of record in seconds
	// contains filtered or unexported fields
}

func (*Topic) Descriptor deprecated 

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

Deprecated: Use Topic.ProtoReflect.Descriptor instead.

func (*Topic) GetArchived 

func (x *Topic) GetArchived() bool

func (*Topic) GetName 

func (x *Topic) GetName() string

func (*Topic) GetPartitions 

func (x *Topic) GetPartitions() int64

func (*Topic) GetTtl 

func (x *Topic) GetTtl() int64

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

func (*Topic) Validate 

func (m *Topic) Validate() error

Validate checks the field values on Topic with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Topic) ValidateAll 

func (m *Topic) ValidateAll() error

ValidateAll checks the field values on Topic with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in TopicMultiError, or nil if none found.

type TopicConsumer 

type TopicConsumer struct {
	Id         string  `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Topic      string  `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	Group      string  `protobuf:"bytes,3,opt,name=group,proto3" json:"group,omitempty"`
	Partitions []int64 `protobuf:"varint,4,rep,packed,name=partitions,proto3" json:"partitions,omitempty"`
	Position   string  `protobuf:"bytes,5,opt,name=position,proto3" json:"position,omitempty"`
	// contains filtered or unexported fields
}

func (*TopicConsumer) Descriptor deprecated 

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

Deprecated: Use TopicConsumer.ProtoReflect.Descriptor instead.

func (*TopicConsumer) GetGroup 

func (x *TopicConsumer) GetGroup() string

func (*TopicConsumer) GetId 

func (x *TopicConsumer) GetId() string

func (*TopicConsumer) GetPartitions 

func (x *TopicConsumer) GetPartitions() []int64

func (*TopicConsumer) GetPosition 

func (x *TopicConsumer) GetPosition() string

func (*TopicConsumer) GetTopic 

func (x *TopicConsumer) GetTopic() string

func (*TopicConsumer) ProtoMessage 

func (*TopicConsumer) ProtoMessage()

func (*TopicConsumer) ProtoReflect 

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

func (*TopicConsumer) Reset 

func (x *TopicConsumer) Reset()

func (*TopicConsumer) String 

func (x *TopicConsumer) String() string

func (*TopicConsumer) Validate 

func (m *TopicConsumer) Validate() error

Validate checks the field values on TopicConsumer with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*TopicConsumer) ValidateAll 

func (m *TopicConsumer) ValidateAll() error

ValidateAll checks the field values on TopicConsumer with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in TopicConsumerMultiError, or nil if none found.

type TopicConsumerMultiError 

type TopicConsumerMultiError []error

TopicConsumerMultiError is an error wrapping multiple validation errors returned by TopicConsumer.ValidateAll() if the designated constraints aren't met.

func (TopicConsumerMultiError) AllErrors 

func (m TopicConsumerMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TopicConsumerMultiError) Error 

func (m TopicConsumerMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type TopicConsumerValidationError 

type TopicConsumerValidationError struct {
	// contains filtered or unexported fields
}

TopicConsumerValidationError is the validation error returned by TopicConsumer.Validate if the designated constraints aren't met.

func (TopicConsumerValidationError) Cause 

func (e TopicConsumerValidationError) Cause() error

Cause function returns cause value.

func (TopicConsumerValidationError) Error 

func (e TopicConsumerValidationError) Error() string

Error satisfies the builtin error interface

func (TopicConsumerValidationError) ErrorName 

func (e TopicConsumerValidationError) ErrorName() string

ErrorName returns error name.

func (TopicConsumerValidationError) Field 

func (e TopicConsumerValidationError) Field() string

Field function returns field value.

func (TopicConsumerValidationError) Key 

func (e TopicConsumerValidationError) Key() bool

Key function returns key value.

func (TopicConsumerValidationError) Reason 

func (e TopicConsumerValidationError) Reason() string

Reason function returns reason value.

type TopicMetadata 

type TopicMetadata struct {
	Name          string                      `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	RecordCount   int64                       `protobuf:"varint,2,opt,name=record_count,json=recordCount,proto3" json:"record_count,omitempty"`
	CreatedAt     *timestamppb.Timestamp      `protobuf:"bytes,3,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	Archived      bool                        `protobuf:"varint,4,opt,name=archived,proto3" json:"archived,omitempty"`
	GroupMetadata map[string]*GroupPartitions `` /* 188-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*TopicMetadata) Descriptor deprecated 

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

Deprecated: Use TopicMetadata.ProtoReflect.Descriptor instead.

func (*TopicMetadata) GetArchived 

func (x *TopicMetadata) GetArchived() bool

func (*TopicMetadata) GetCreatedAt 

func (x *TopicMetadata) GetCreatedAt() *timestamppb.Timestamp

func (*TopicMetadata) GetGroupMetadata 

func (x *TopicMetadata) GetGroupMetadata() map[string]*GroupPartitions

func (*TopicMetadata) GetName 

func (x *TopicMetadata) GetName() string

func (*TopicMetadata) GetRecordCount 

func (x *TopicMetadata) GetRecordCount() int64

func (*TopicMetadata) ProtoMessage 

func (*TopicMetadata) ProtoMessage()

func (*TopicMetadata) ProtoReflect 

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

func (*TopicMetadata) Reset 

func (x *TopicMetadata) Reset()

func (*TopicMetadata) String 

func (x *TopicMetadata) String() string

func (*TopicMetadata) Validate 

func (m *TopicMetadata) Validate() error

Validate checks the field values on TopicMetadata with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*TopicMetadata) ValidateAll 

func (m *TopicMetadata) ValidateAll() error

ValidateAll checks the field values on TopicMetadata with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in TopicMetadataMultiError, or nil if none found.

type TopicMetadataMultiError 

type TopicMetadataMultiError []error

TopicMetadataMultiError is an error wrapping multiple validation errors returned by TopicMetadata.ValidateAll() if the designated constraints aren't met.

func (TopicMetadataMultiError) AllErrors 

func (m TopicMetadataMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TopicMetadataMultiError) Error 

func (m TopicMetadataMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type TopicMetadataValidationError 

type TopicMetadataValidationError struct {
	// contains filtered or unexported fields
}

TopicMetadataValidationError is the validation error returned by TopicMetadata.Validate if the designated constraints aren't met.

func (TopicMetadataValidationError) Cause 

func (e TopicMetadataValidationError) Cause() error

Cause function returns cause value.

func (TopicMetadataValidationError) Error 

func (e TopicMetadataValidationError) Error() string

Error satisfies the builtin error interface

func (TopicMetadataValidationError) ErrorName 

func (e TopicMetadataValidationError) ErrorName() string

ErrorName returns error name.

func (TopicMetadataValidationError) Field 

func (e TopicMetadataValidationError) Field() string

Field function returns field value.

func (TopicMetadataValidationError) Key 

func (e TopicMetadataValidationError) Key() bool

Key function returns key value.

func (TopicMetadataValidationError) Reason 

func (e TopicMetadataValidationError) Reason() string

Reason function returns reason value.

type TopicMultiError 

type TopicMultiError []error

TopicMultiError is an error wrapping multiple validation errors returned by Topic.ValidateAll() if the designated constraints aren't met.

func (TopicMultiError) AllErrors 

func (m TopicMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TopicMultiError) Error 

func (m TopicMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type TopicValidationError 

type TopicValidationError struct {
	// contains filtered or unexported fields
}

TopicValidationError is the validation error returned by Topic.Validate if the designated constraints aren't met.

func (TopicValidationError) Cause 

func (e TopicValidationError) Cause() error

Cause function returns cause value.

func (TopicValidationError) Error 

func (e TopicValidationError) Error() string

Error satisfies the builtin error interface

func (TopicValidationError) ErrorName 

func (e TopicValidationError) ErrorName() string

ErrorName returns error name.

func (TopicValidationError) Field 

func (e TopicValidationError) Field() string

Field function returns field value.

func (TopicValidationError) Key 

func (e TopicValidationError) Key() bool

Key function returns key value.

func (TopicValidationError) Reason 

func (e TopicValidationError) Reason() string

Reason function returns reason value.

type UnimplementedKayakServiceServer 

type UnimplementedKayakServiceServer struct {
}

UnimplementedKayakServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedKayakServiceServer) Apply 

func (UnimplementedKayakServiceServer) Apply(context.Context, *Command) (*ApplyResponse, error)

func (UnimplementedKayakServiceServer) CommitRecord 

func (UnimplementedKayakServiceServer) CommitRecord(context.Context, *CommitRecordRequest) (*emptypb.Empty, error)

func (UnimplementedKayakServiceServer) CreateTopic 

func (UnimplementedKayakServiceServer) CreateTopic(context.Context, *CreateTopicRequest) (*emptypb.Empty, error)

func (UnimplementedKayakServiceServer) DeleteTopic 

func (UnimplementedKayakServiceServer) DeleteTopic(context.Context, *DeleteTopicRequest) (*emptypb.Empty, error)

func (UnimplementedKayakServiceServer) FetchRecord 

func (UnimplementedKayakServiceServer) FetchRecord(context.Context, *FetchRecordRequest) (*FetchRecordsResponse, error)

func (UnimplementedKayakServiceServer) GetNodeDetails 

func (UnimplementedKayakServiceServer) GetNodeDetails(context.Context, *emptypb.Empty) (*GetNodeDetailsResponse, error)

func (UnimplementedKayakServiceServer) GetRecords 

func (UnimplementedKayakServiceServer) GetRecords(context.Context, *GetRecordsRequest) (*GetRecordsResponse, error)

func (UnimplementedKayakServiceServer) ListTopics 

func (UnimplementedKayakServiceServer) ListTopics(context.Context, *ListTopicsRequest) (*ListTopicsResponse, error)

func (UnimplementedKayakServiceServer) PutRecords 

func (UnimplementedKayakServiceServer) PutRecords(context.Context, *PutRecordsRequest) (*emptypb.Empty, error)

func (UnimplementedKayakServiceServer) RegisterConsumer 

func (UnimplementedKayakServiceServer) RegisterConsumer(context.Context, *RegisterConsumerRequest) (*emptypb.Empty, error)

func (UnimplementedKayakServiceServer) Stats 

func (UnimplementedKayakServiceServer) Stats(context.Context, *emptypb.Empty) (*StatsResponse, error)

func (UnimplementedKayakServiceServer) StreamRecords 

func (UnimplementedKayakServiceServer) StreamRecords(*StreamRecordsRequest, KayakService_StreamRecordsServer) error

type UnsafeKayakServiceServer 

type UnsafeKayakServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeKayakServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to KayakServiceServer will result in compilation errors.

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.