internal_topics_pb

package
v0.0.0-...-fcf41b5 Latest Latest
Warning

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

 Go to latest Published: Apr 3, 2022 License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ACLMessageKey_Operation_name = map[int32]string{
		0:  "OPERATION_RESERVED",
		2:  "OPERATION_ALL",
		3:  "OPERATION_READ",
		4:  "OPERATION_WRITE",
		5:  "OPERATION_CREATE",
		6:  "OPERATION_DELETE",
		7:  "OPERATION_ALTER",
		8:  "OPERATION_DESCRIBE",
		9:  "OPERATION_CLUSTER_ACTION",
		10: "OPERATION_DESCRIBE_CONFIGS",
		11: "OPERATION_ALTER_CONFIGS",
		12: "OPERATION_IDEMPOTENT_WRITE",
	}
	ACLMessageKey_Operation_value = map[string]int32{
		"OPERATION_RESERVED":         0,
		"OPERATION_ALL":              2,
		"OPERATION_READ":             3,
		"OPERATION_WRITE":            4,
		"OPERATION_CREATE":           5,
		"OPERATION_DELETE":           6,
		"OPERATION_ALTER":            7,
		"OPERATION_DESCRIBE":         8,
		"OPERATION_CLUSTER_ACTION":   9,
		"OPERATION_DESCRIBE_CONFIGS": 10,
		"OPERATION_ALTER_CONFIGS":    11,
		"OPERATION_IDEMPOTENT_WRITE": 12,
	}
)

Enum value maps for ACLMessageKey_Operation.

View Source 
var (
	ACLMessageKey_ResourceType_name = map[int32]string{
		0: "RESOURCE_TYPE_RESERVED",
		2: "RESOURCE_TYPE_TOPIC",
		3: "RESOURCE_TYPE_GROUP",
		4: "RESOURCE_TYPE_CLUSTER",
		5: "RESOURCE_TYPE_TRANSACTIONAL_ID",
		6: "RESOURCE_TYPE_DELEGATION_TOKEN",
	}
	ACLMessageKey_ResourceType_value = map[string]int32{
		"RESOURCE_TYPE_RESERVED":         0,
		"RESOURCE_TYPE_TOPIC":            2,
		"RESOURCE_TYPE_GROUP":            3,
		"RESOURCE_TYPE_CLUSTER":          4,
		"RESOURCE_TYPE_TRANSACTIONAL_ID": 5,
		"RESOURCE_TYPE_DELEGATION_TOKEN": 6,
	}
)

Enum value maps for ACLMessageKey_ResourceType.

View Source 
var (
	ACLMessageKey_PatternType_name = map[int32]string{
		0: "PATTERN_TYPE_RESERVED",
		2: "PATTERN_TYPE_MATCH",
		3: "PATTERN_TYPE_LITERAL",
		4: "PATTERN_TYPE_PREFIXED",
	}
	ACLMessageKey_PatternType_value = map[string]int32{
		"PATTERN_TYPE_RESERVED": 0,
		"PATTERN_TYPE_MATCH":    2,
		"PATTERN_TYPE_LITERAL":  3,
		"PATTERN_TYPE_PREFIXED": 4,
	}
)

Enum value maps for ACLMessageKey_PatternType.

View Source 
var (
	ACLMessageValue_Permission_name = map[int32]string{
		0: "PERMISSION_RESERVED",
		2: "PERMISSION_DENY",
		3: "PERMISSION_ALLOW",
	}
	ACLMessageValue_Permission_value = map[string]int32{
		"PERMISSION_RESERVED": 0,
		"PERMISSION_DENY":     2,
		"PERMISSION_ALLOW":    3,
	}
)

Enum value maps for ACLMessageValue_Permission.

View Source 
var (
	TopicMessageValue_Action_name = map[int32]string{
		0: "ACTION_CREATE",
		1: "ACTION_UPDATE",
		2: "ACTION_DELETE",
	}
	TopicMessageValue_Action_value = map[string]int32{
		"ACTION_CREATE": 0,
		"ACTION_UPDATE": 1,
		"ACTION_DELETE": 2,
	}
)

Enum value maps for TopicMessageValue_Action.

View Source 
var File_acl_proto protoreflect.FileDescriptor
View Source 
var File_broker_proto protoreflect.FileDescriptor
View Source 
var File_topic_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type ACLMessageKey 

type ACLMessageKey struct {
	Operation    ACLMessageKey_Operation    `protobuf:"varint,1,opt,name=operation,proto3,enum=proto.ACLMessageKey_Operation" json:"operation,omitempty"`
	ResourceType ACLMessageKey_ResourceType `` /* 136-byte string literal not displayed */
	PatternType  ACLMessageKey_PatternType  `` /* 132-byte string literal not displayed */
	ResourceName string                     `protobuf:"bytes,4,opt,name=resource_name,json=resourceName,proto3" json:"resource_name,omitempty"`
	Principal    string                     `protobuf:"bytes,5,opt,name=principal,proto3" json:"principal,omitempty"`
	// contains filtered or unexported fields
}

func (*ACLMessageKey) Descriptor deprecated 

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

Deprecated: Use ACLMessageKey.ProtoReflect.Descriptor instead.

func (*ACLMessageKey) GetOperation 

func (x *ACLMessageKey) GetOperation() ACLMessageKey_Operation

func (*ACLMessageKey) GetPatternType 

func (x *ACLMessageKey) GetPatternType() ACLMessageKey_PatternType

func (*ACLMessageKey) GetPrincipal 

func (x *ACLMessageKey) GetPrincipal() string

func (*ACLMessageKey) GetResourceName 

func (x *ACLMessageKey) GetResourceName() string

func (*ACLMessageKey) GetResourceType 

func (x *ACLMessageKey) GetResourceType() ACLMessageKey_ResourceType

func (*ACLMessageKey) ProtoMessage 

func (*ACLMessageKey) ProtoMessage()

func (*ACLMessageKey) ProtoReflect 

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

func (*ACLMessageKey) Reset 

func (x *ACLMessageKey) Reset()

func (*ACLMessageKey) String 

func (x *ACLMessageKey) String() string

type ACLMessageKey_Operation 

type ACLMessageKey_Operation int32
const (
	ACLMessageKey_OPERATION_RESERVED         ACLMessageKey_Operation = 0
	ACLMessageKey_OPERATION_ALL              ACLMessageKey_Operation = 2
	ACLMessageKey_OPERATION_READ             ACLMessageKey_Operation = 3
	ACLMessageKey_OPERATION_WRITE            ACLMessageKey_Operation = 4
	ACLMessageKey_OPERATION_CREATE           ACLMessageKey_Operation = 5
	ACLMessageKey_OPERATION_DELETE           ACLMessageKey_Operation = 6
	ACLMessageKey_OPERATION_ALTER            ACLMessageKey_Operation = 7
	ACLMessageKey_OPERATION_DESCRIBE         ACLMessageKey_Operation = 8
	ACLMessageKey_OPERATION_CLUSTER_ACTION   ACLMessageKey_Operation = 9
	ACLMessageKey_OPERATION_DESCRIBE_CONFIGS ACLMessageKey_Operation = 10
	ACLMessageKey_OPERATION_ALTER_CONFIGS    ACLMessageKey_Operation = 11
	ACLMessageKey_OPERATION_IDEMPOTENT_WRITE ACLMessageKey_Operation = 12
)

func (ACLMessageKey_Operation) Descriptor 

func (ACLMessageKey_Operation) Descriptor() protoreflect.EnumDescriptor

func (ACLMessageKey_Operation) Enum 

func (x ACLMessageKey_Operation) Enum() *ACLMessageKey_Operation

func (ACLMessageKey_Operation) EnumDescriptor deprecated 

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

Deprecated: Use ACLMessageKey_Operation.Descriptor instead.

func (ACLMessageKey_Operation) Number 

func (x ACLMessageKey_Operation) Number() protoreflect.EnumNumber

func (ACLMessageKey_Operation) String 

func (x ACLMessageKey_Operation) String() string

func (ACLMessageKey_Operation) Type 

func (ACLMessageKey_Operation) Type() protoreflect.EnumType

type ACLMessageKey_PatternType 

type ACLMessageKey_PatternType int32
const (
	ACLMessageKey_PATTERN_TYPE_RESERVED ACLMessageKey_PatternType = 0
	ACLMessageKey_PATTERN_TYPE_MATCH    ACLMessageKey_PatternType = 2
	ACLMessageKey_PATTERN_TYPE_LITERAL  ACLMessageKey_PatternType = 3
	ACLMessageKey_PATTERN_TYPE_PREFIXED ACLMessageKey_PatternType = 4
)

func (ACLMessageKey_PatternType) Descriptor 

func (ACLMessageKey_PatternType) Descriptor() protoreflect.EnumDescriptor

func (ACLMessageKey_PatternType) Enum 

func (x ACLMessageKey_PatternType) Enum() *ACLMessageKey_PatternType

func (ACLMessageKey_PatternType) EnumDescriptor deprecated 

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

Deprecated: Use ACLMessageKey_PatternType.Descriptor instead.

func (ACLMessageKey_PatternType) Number 

func (x ACLMessageKey_PatternType) Number() protoreflect.EnumNumber

func (ACLMessageKey_PatternType) String 

func (x ACLMessageKey_PatternType) String() string

func (ACLMessageKey_PatternType) Type 

func (ACLMessageKey_PatternType) Type() protoreflect.EnumType

type ACLMessageKey_ResourceType 

type ACLMessageKey_ResourceType int32
const (
	ACLMessageKey_RESOURCE_TYPE_RESERVED         ACLMessageKey_ResourceType = 0
	ACLMessageKey_RESOURCE_TYPE_TOPIC            ACLMessageKey_ResourceType = 2
	ACLMessageKey_RESOURCE_TYPE_GROUP            ACLMessageKey_ResourceType = 3
	ACLMessageKey_RESOURCE_TYPE_CLUSTER          ACLMessageKey_ResourceType = 4
	ACLMessageKey_RESOURCE_TYPE_TRANSACTIONAL_ID ACLMessageKey_ResourceType = 5
	ACLMessageKey_RESOURCE_TYPE_DELEGATION_TOKEN ACLMessageKey_ResourceType = 6
)

func (ACLMessageKey_ResourceType) Descriptor 

func (ACLMessageKey_ResourceType) Descriptor() protoreflect.EnumDescriptor

func (ACLMessageKey_ResourceType) Enum 

func (x ACLMessageKey_ResourceType) Enum() *ACLMessageKey_ResourceType

func (ACLMessageKey_ResourceType) EnumDescriptor deprecated 

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

Deprecated: Use ACLMessageKey_ResourceType.Descriptor instead.

func (ACLMessageKey_ResourceType) Number 

func (x ACLMessageKey_ResourceType) Number() protoreflect.EnumNumber

func (ACLMessageKey_ResourceType) String 

func (x ACLMessageKey_ResourceType) String() string

func (ACLMessageKey_ResourceType) Type 

func (ACLMessageKey_ResourceType) Type() protoreflect.EnumType

type ACLMessageValue 

type ACLMessageValue struct {
	Permission ACLMessageValue_Permission `protobuf:"varint,1,opt,name=permission,proto3,enum=proto.ACLMessageValue_Permission" json:"permission,omitempty"`
	// contains filtered or unexported fields
}

func (*ACLMessageValue) Descriptor deprecated 

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

Deprecated: Use ACLMessageValue.ProtoReflect.Descriptor instead.

func (*ACLMessageValue) GetPermission 

func (x *ACLMessageValue) GetPermission() ACLMessageValue_Permission

func (*ACLMessageValue) ProtoMessage 

func (*ACLMessageValue) ProtoMessage()

func (*ACLMessageValue) ProtoReflect 

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

func (*ACLMessageValue) Reset 

func (x *ACLMessageValue) Reset()

func (*ACLMessageValue) String 

func (x *ACLMessageValue) String() string

type ACLMessageValue_Permission 

type ACLMessageValue_Permission int32
const (
	ACLMessageValue_PERMISSION_RESERVED ACLMessageValue_Permission = 0
	ACLMessageValue_PERMISSION_DENY     ACLMessageValue_Permission = 2
	ACLMessageValue_PERMISSION_ALLOW    ACLMessageValue_Permission = 3
)

func (ACLMessageValue_Permission) Descriptor 

func (ACLMessageValue_Permission) Descriptor() protoreflect.EnumDescriptor

func (ACLMessageValue_Permission) Enum 

func (x ACLMessageValue_Permission) Enum() *ACLMessageValue_Permission

func (ACLMessageValue_Permission) EnumDescriptor deprecated 

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

Deprecated: Use ACLMessageValue_Permission.Descriptor instead.

func (ACLMessageValue_Permission) Number 

func (x ACLMessageValue_Permission) Number() protoreflect.EnumNumber

func (ACLMessageValue_Permission) String 

func (x ACLMessageValue_Permission) String() string

func (ACLMessageValue_Permission) Type 

func (ACLMessageValue_Permission) Type() protoreflect.EnumType

type BrokerEndpoint 

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

func (*BrokerEndpoint) Descriptor deprecated 

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

Deprecated: Use BrokerEndpoint.ProtoReflect.Descriptor instead.

func (*BrokerEndpoint) GetHost 

func (x *BrokerEndpoint) GetHost() string

func (*BrokerEndpoint) GetPort 

func (x *BrokerEndpoint) GetPort() int32

func (*BrokerEndpoint) ProtoMessage 

func (*BrokerEndpoint) ProtoMessage()

func (*BrokerEndpoint) ProtoReflect 

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

func (*BrokerEndpoint) Reset 

func (x *BrokerEndpoint) Reset()

func (*BrokerEndpoint) String 

func (x *BrokerEndpoint) String() string

type BrokerMessageKey 

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

func (*BrokerMessageKey) Descriptor deprecated 

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

Deprecated: Use BrokerMessageKey.ProtoReflect.Descriptor instead.

func (*BrokerMessageKey) GetBrokerId 

func (x *BrokerMessageKey) GetBrokerId() int32

func (*BrokerMessageKey) ProtoMessage 

func (*BrokerMessageKey) ProtoMessage()

func (*BrokerMessageKey) ProtoReflect 

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

func (*BrokerMessageKey) Reset 

func (x *BrokerMessageKey) Reset()

func (*BrokerMessageKey) String 

func (x *BrokerMessageKey) String() string

type BrokerMessageValue 

type BrokerMessageValue struct {
	Endpoint *BrokerEndpoint `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	Rack     string          `protobuf:"bytes,2,opt,name=rack,proto3" json:"rack,omitempty"`
	// contains filtered or unexported fields
}

func (*BrokerMessageValue) Descriptor deprecated 

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

Deprecated: Use BrokerMessageValue.ProtoReflect.Descriptor instead.

func (*BrokerMessageValue) GetEndpoint 

func (x *BrokerMessageValue) GetEndpoint() *BrokerEndpoint

func (*BrokerMessageValue) GetRack 

func (x *BrokerMessageValue) GetRack() string

func (*BrokerMessageValue) ProtoMessage 

func (*BrokerMessageValue) ProtoMessage()

func (*BrokerMessageValue) ProtoReflect 

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

func (*BrokerMessageValue) Reset 

func (x *BrokerMessageValue) Reset()

func (*BrokerMessageValue) String 

func (x *BrokerMessageValue) String() string

type Topic 

type Topic struct {
	Name       string                             `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Partitions int32                              `protobuf:"varint,2,opt,name=partitions,proto3" json:"partitions,omitempty"`
	Config     map[string]*wrapperspb.StringValue `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Topic) Descriptor deprecated 

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

Deprecated: Use Topic.ProtoReflect.Descriptor instead.

func (*Topic) GetConfig 

func (x *Topic) GetConfig() map[string]*wrapperspb.StringValue

func (*Topic) GetName 

func (x *Topic) GetName() string

func (*Topic) GetPartitions 

func (x *Topic) GetPartitions() int32

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

type TopicMessageValue 

type TopicMessageValue struct {
	Name    string                   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Action  TopicMessageValue_Action `protobuf:"varint,2,opt,name=action,proto3,enum=proto.TopicMessageValue_Action" json:"action,omitempty"`
	Cluster string                   `protobuf:"bytes,3,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Topic   *Topic                   `protobuf:"bytes,4,opt,name=topic,proto3" json:"topic,omitempty"`
	// contains filtered or unexported fields
}

func (*TopicMessageValue) Descriptor deprecated 

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

Deprecated: Use TopicMessageValue.ProtoReflect.Descriptor instead.

func (*TopicMessageValue) GetAction 

func (x *TopicMessageValue) GetAction() TopicMessageValue_Action

func (*TopicMessageValue) GetCluster 

func (x *TopicMessageValue) GetCluster() string

func (*TopicMessageValue) GetName 

func (x *TopicMessageValue) GetName() string

func (*TopicMessageValue) GetTopic 

func (x *TopicMessageValue) GetTopic() *Topic

func (*TopicMessageValue) ProtoMessage 

func (*TopicMessageValue) ProtoMessage()

func (*TopicMessageValue) ProtoReflect 

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

func (*TopicMessageValue) Reset 

func (x *TopicMessageValue) Reset()

func (*TopicMessageValue) String 

func (x *TopicMessageValue) String() string

type TopicMessageValue_Action 

type TopicMessageValue_Action int32
const (
	TopicMessageValue_ACTION_CREATE TopicMessageValue_Action = 0
	TopicMessageValue_ACTION_UPDATE TopicMessageValue_Action = 1
	TopicMessageValue_ACTION_DELETE TopicMessageValue_Action = 2
)

func (TopicMessageValue_Action) Descriptor 

func (TopicMessageValue_Action) Descriptor() protoreflect.EnumDescriptor

func (TopicMessageValue_Action) Enum 

func (x TopicMessageValue_Action) Enum() *TopicMessageValue_Action

func (TopicMessageValue_Action) EnumDescriptor deprecated 

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

Deprecated: Use TopicMessageValue_Action.Descriptor instead.

func (TopicMessageValue_Action) Number 

func (x TopicMessageValue_Action) Number() protoreflect.EnumNumber

func (TopicMessageValue_Action) String 

func (x TopicMessageValue_Action) String() string

func (TopicMessageValue_Action) Type 

func (TopicMessageValue_Action) Type() protoreflect.EnumType

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.