envv1

package
v0.0.0-...-4ad3c4e Latest Latest
Warning

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

 Go to latest Published: Mar 4, 2023 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_proto_env_v1_env_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Env 

type Env struct {
	Nodes []*RPCNode `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
	Kafka *Kafka     `protobuf:"bytes,2,opt,name=kafka,proto3" json:"kafka,omitempty"`
	// contains filtered or unexported fields
}

func (*Env) Descriptor deprecated 

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

Deprecated: Use Env.ProtoReflect.Descriptor instead.

func (*Env) GetKafka 

func (x *Env) GetKafka() *Kafka

func (*Env) GetNodes 

func (x *Env) GetNodes() []*RPCNode

func (*Env) ProtoMessage 

func (*Env) ProtoMessage()

func (*Env) ProtoReflect 

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

func (*Env) Reset 

func (x *Env) Reset()

func (*Env) String 

func (x *Env) String() string

type Kafka 

type Kafka struct {

	// List of seed brokers.
	Brokers []string `protobuf:"bytes,1,rep,name=brokers,proto3" json:"brokers,omitempty"`
	// Topic prefix (dot notation). The topic name is the prefix + application-specific name.
	TopicPrefix string `protobuf:"bytes,2,opt,name=topic_prefix,json=topicPrefix,proto3" json:"topic_prefix,omitempty"`
	// Authentication method.
	//
	// Types that are assignable to Auth:
	//	*Kafka_NoAuth
	//	*Kafka_SaslAuth
	Auth isKafka_Auth `protobuf_oneof:"auth"`
	// Encryption
	//
	// Types that are assignable to Encryption:
	//	*Kafka_TlsEncryption
	Encryption isKafka_Encryption `protobuf_oneof:"encryption"`
	// contains filtered or unexported fields
}

func (*Kafka) Descriptor deprecated 

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

Deprecated: Use Kafka.ProtoReflect.Descriptor instead.

func (*Kafka) GetAuth 

func (m *Kafka) GetAuth() isKafka_Auth

func (*Kafka) GetBrokers 

func (x *Kafka) GetBrokers() []string

func (*Kafka) GetEncryption 

func (m *Kafka) GetEncryption() isKafka_Encryption

func (*Kafka) GetNoAuth 

func (x *Kafka) GetNoAuth() *Kafka_KafkaNoAuth

func (*Kafka) GetSaslAuth 

func (x *Kafka) GetSaslAuth() *Kafka_KafkaSASLAuth

func (*Kafka) GetTlsEncryption 

func (x *Kafka) GetTlsEncryption() *Kafka_KafkaTLSEncryption

func (*Kafka) GetTopicPrefix 

func (x *Kafka) GetTopicPrefix() string

func (*Kafka) ProtoMessage 

func (*Kafka) ProtoMessage()

func (*Kafka) ProtoReflect 

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

func (*Kafka) Reset 

func (x *Kafka) Reset()

func (*Kafka) String 

func (x *Kafka) String() string

type Kafka_KafkaNoAuth 

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

func (*Kafka_KafkaNoAuth) Descriptor deprecated 

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

Deprecated: Use Kafka_KafkaNoAuth.ProtoReflect.Descriptor instead.

func (*Kafka_KafkaNoAuth) ProtoMessage 

func (*Kafka_KafkaNoAuth) ProtoMessage()

func (*Kafka_KafkaNoAuth) ProtoReflect 

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

func (*Kafka_KafkaNoAuth) Reset 

func (x *Kafka_KafkaNoAuth) Reset()

func (*Kafka_KafkaNoAuth) String 

func (x *Kafka_KafkaNoAuth) String() string

type Kafka_KafkaSASLAuth 

type Kafka_KafkaSASLAuth struct {
	Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	// contains filtered or unexported fields
}

SASL SCRAM-SHA-256 authentication.

func (*Kafka_KafkaSASLAuth) Descriptor deprecated 

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

Deprecated: Use Kafka_KafkaSASLAuth.ProtoReflect.Descriptor instead.

func (*Kafka_KafkaSASLAuth) GetPassword 

func (x *Kafka_KafkaSASLAuth) GetPassword() string

func (*Kafka_KafkaSASLAuth) GetUsername 

func (x *Kafka_KafkaSASLAuth) GetUsername() string

func (*Kafka_KafkaSASLAuth) ProtoMessage 

func (*Kafka_KafkaSASLAuth) ProtoMessage()

func (*Kafka_KafkaSASLAuth) ProtoReflect 

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

func (*Kafka_KafkaSASLAuth) Reset 

func (x *Kafka_KafkaSASLAuth) Reset()

func (*Kafka_KafkaSASLAuth) String 

func (x *Kafka_KafkaSASLAuth) String() string

type Kafka_KafkaTLSEncryption 

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

TLS encryption.

func (*Kafka_KafkaTLSEncryption) Descriptor deprecated 

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

Deprecated: Use Kafka_KafkaTLSEncryption.ProtoReflect.Descriptor instead.

func (*Kafka_KafkaTLSEncryption) ProtoMessage 

func (*Kafka_KafkaTLSEncryption) ProtoMessage()

func (*Kafka_KafkaTLSEncryption) ProtoReflect 

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

func (*Kafka_KafkaTLSEncryption) Reset 

func (x *Kafka_KafkaTLSEncryption) Reset()

func (*Kafka_KafkaTLSEncryption) String 

func (x *Kafka_KafkaTLSEncryption) String() string

type Kafka_NoAuth 

type Kafka_NoAuth struct {
	// No authentication.
	NoAuth *Kafka_KafkaNoAuth `protobuf:"bytes,3,opt,name=no_auth,json=noAuth,proto3,oneof"`
}

type Kafka_SaslAuth 

type Kafka_SaslAuth struct {
	// SASL authentication.
	SaslAuth *Kafka_KafkaSASLAuth `protobuf:"bytes,4,opt,name=sasl_auth,json=saslAuth,proto3,oneof"`
}

type Kafka_TlsEncryption 

type Kafka_TlsEncryption struct {
	// TLS encryption.
	TlsEncryption *Kafka_KafkaTLSEncryption `protobuf:"bytes,6,opt,name=tls_encryption,json=tlsEncryption,proto3,oneof"`
}

type RPCNode 

type RPCNode struct {
	Name string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Http string   `protobuf:"bytes,2,opt,name=http,proto3" json:"http,omitempty"`
	Ws   string   `protobuf:"bytes,3,opt,name=ws,proto3" json:"ws,omitempty"`
	Tag  []string `protobuf:"bytes,4,rep,name=tag,proto3" json:"tag,omitempty"`
	// contains filtered or unexported fields
}

func (*RPCNode) Descriptor deprecated 

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

Deprecated: Use RPCNode.ProtoReflect.Descriptor instead.

func (*RPCNode) GetHttp 

func (x *RPCNode) GetHttp() string

func (*RPCNode) GetName 

func (x *RPCNode) GetName() string

func (*RPCNode) GetTag 

func (x *RPCNode) GetTag() []string

func (*RPCNode) GetWs 

func (x *RPCNode) GetWs() string

func (*RPCNode) ProtoMessage 

func (*RPCNode) ProtoMessage()

func (*RPCNode) ProtoReflect 

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

func (*RPCNode) Reset 

func (x *RPCNode) Reset()

func (*RPCNode) String 

func (x *RPCNode) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

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