conf

package
v0.0.0-...-150877d Latest Latest
Warning

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

Go to latest
Published: Jul 19, 2022 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var File_consul_proto protoreflect.FileDescriptor
View Source
var File_database_proto protoreflect.FileDescriptor
View Source
var File_email_proto protoreflect.FileDescriptor
View Source
var File_object_storage_proto protoreflect.FileDescriptor
View Source
var File_queue_proto protoreflect.FileDescriptor
View Source
var File_redis_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Consul

type Consul struct {
	Address    string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`       // Consul 服务器地址
	Scheme     string `protobuf:"bytes,2,opt,name=scheme,proto3" json:"scheme,omitempty"`         // Consul 服务器的 URI 方案 ("http" or "grpc")
	Datacenter string `protobuf:"bytes,3,opt,name=datacenter,proto3" json:"datacenter,omitempty"` // 数据中心
	Path       string `protobuf:"bytes,4,opt,name=path,proto3" json:"path,omitempty"`             // 配置文件路径
	// contains filtered or unexported fields
}

func (*Consul) Descriptor deprecated

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

Deprecated: Use Consul.ProtoReflect.Descriptor instead.

func (*Consul) GetAddress

func (x *Consul) GetAddress() string

func (*Consul) GetDatacenter

func (x *Consul) GetDatacenter() string

func (*Consul) GetPath

func (x *Consul) GetPath() string

func (*Consul) GetScheme

func (x *Consul) GetScheme() string

func (*Consul) ProtoMessage

func (*Consul) ProtoMessage()

func (*Consul) ProtoReflect

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

func (*Consul) Reset

func (x *Consul) Reset()

func (*Consul) String

func (x *Consul) String() string

type Database

type Database struct {
	Source          string             `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
	MaxIdleConn     uint32             `protobuf:"varint,2,opt,name=max_idle_conn,json=maxIdleConn,proto3" json:"max_idle_conn,omitempty"`
	MaxOpenConn     uint32             `protobuf:"varint,3,opt,name=max_open_conn,json=maxOpenConn,proto3" json:"max_open_conn,omitempty"`
	ConnMaxLifetime *duration.Duration `protobuf:"bytes,4,opt,name=conn_max_lifetime,json=connMaxLifetime,proto3" json:"conn_max_lifetime,omitempty"`
	// contains filtered or unexported fields
}

func (*Database) Descriptor deprecated

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

Deprecated: Use Database.ProtoReflect.Descriptor instead.

func (*Database) GetConnMaxLifetime

func (x *Database) GetConnMaxLifetime() *duration.Duration

func (*Database) GetMaxIdleConn

func (x *Database) GetMaxIdleConn() uint32

func (*Database) GetMaxOpenConn

func (x *Database) GetMaxOpenConn() uint32

func (*Database) GetSource

func (x *Database) GetSource() string

func (*Database) ProtoMessage

func (*Database) ProtoMessage()

func (*Database) ProtoReflect

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

func (*Database) Reset

func (x *Database) Reset()

func (*Database) String

func (x *Database) String() string

type Email

type Email struct {
	Host     string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	Port     uint32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	Username string `protobuf:"bytes,3,opt,name=username,proto3" json:"username,omitempty"`
	Password string `protobuf:"bytes,4,opt,name=password,proto3" json:"password,omitempty"`
	// contains filtered or unexported fields
}

func (*Email) Descriptor deprecated

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

Deprecated: Use Email.ProtoReflect.Descriptor instead.

func (*Email) GetHost

func (x *Email) GetHost() string

func (*Email) GetPassword

func (x *Email) GetPassword() string

func (*Email) GetPort

func (x *Email) GetPort() uint32

func (*Email) GetUsername

func (x *Email) GetUsername() string

func (*Email) ProtoMessage

func (*Email) ProtoMessage()

func (*Email) ProtoReflect

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

func (*Email) Reset

func (x *Email) Reset()

func (*Email) String

func (x *Email) String() string

type GRPC

type GRPC struct {
	Network string             `protobuf:"bytes,1,opt,name=network,proto3" json:"network,omitempty"`
	Addr    string             `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`
	Timeout *duration.Duration `protobuf:"bytes,3,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// contains filtered or unexported fields
}

func (*GRPC) Descriptor deprecated

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

Deprecated: Use GRPC.ProtoReflect.Descriptor instead.

func (*GRPC) GetAddr

func (x *GRPC) GetAddr() string

func (*GRPC) GetNetwork

func (x *GRPC) GetNetwork() string

func (*GRPC) GetTimeout

func (x *GRPC) GetTimeout() *duration.Duration

func (*GRPC) ProtoMessage

func (*GRPC) ProtoMessage()

func (*GRPC) ProtoReflect

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

func (*GRPC) Reset

func (x *GRPC) Reset()

func (*GRPC) String

func (x *GRPC) String() string

type HTTP

type HTTP struct {
	Network          string             `protobuf:"bytes,1,opt,name=network,proto3" json:"network,omitempty"`
	Addr             string             `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`
	Timeout          *duration.Duration `protobuf:"bytes,3,opt,name=timeout,proto3" json:"timeout,omitempty"`
	RequiredBodySize uint32             `protobuf:"varint,4,opt,name=required_body_size,json=requiredBodySize,proto3" json:"required_body_size,omitempty"`
	MaxBodySize      uint32             `protobuf:"varint,5,opt,name=max_body_size,json=maxBodySize,proto3" json:"max_body_size,omitempty"`
	// contains filtered or unexported fields
}

func (*HTTP) Descriptor deprecated

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

Deprecated: Use HTTP.ProtoReflect.Descriptor instead.

func (*HTTP) GetAddr

func (x *HTTP) GetAddr() string

func (*HTTP) GetMaxBodySize

func (x *HTTP) GetMaxBodySize() uint32

func (*HTTP) GetNetwork

func (x *HTTP) GetNetwork() string

func (*HTTP) GetRequiredBodySize

func (x *HTTP) GetRequiredBodySize() uint32

func (*HTTP) GetTimeout

func (x *HTTP) GetTimeout() *duration.Duration

func (*HTTP) ProtoMessage

func (*HTTP) ProtoMessage()

func (*HTTP) ProtoReflect

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

func (*HTTP) Reset

func (x *HTTP) Reset()

func (*HTTP) String

func (x *HTTP) String() string

type ObjectStorage

type ObjectStorage struct {
	Domain          string `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"` // 域名
	AccessKeyId     string `protobuf:"bytes,2,opt,name=access_key_id,json=accessKeyId,proto3" json:"access_key_id,omitempty"`
	SecretAccessKey string `protobuf:"bytes,3,opt,name=secret_access_key,json=secretAccessKey,proto3" json:"secret_access_key,omitempty"`
	Location        string `protobuf:"bytes,4,opt,name=location,proto3" json:"location,omitempty"` // 地域
	Secure          bool   `protobuf:"varint,5,opt,name=secure,proto3" json:"secure,omitempty"`    // 是否使用https
	Token           string `protobuf:"bytes,6,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

func (*ObjectStorage) Descriptor deprecated

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

Deprecated: Use ObjectStorage.ProtoReflect.Descriptor instead.

func (*ObjectStorage) GetAccessKeyId

func (x *ObjectStorage) GetAccessKeyId() string

func (*ObjectStorage) GetDomain

func (x *ObjectStorage) GetDomain() string

func (*ObjectStorage) GetLocation

func (x *ObjectStorage) GetLocation() string

func (*ObjectStorage) GetSecretAccessKey

func (x *ObjectStorage) GetSecretAccessKey() string

func (*ObjectStorage) GetSecure

func (x *ObjectStorage) GetSecure() bool

func (*ObjectStorage) GetToken

func (x *ObjectStorage) GetToken() string

func (*ObjectStorage) ProtoMessage

func (*ObjectStorage) ProtoMessage()

func (*ObjectStorage) ProtoReflect

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

func (*ObjectStorage) Reset

func (x *ObjectStorage) Reset()

func (*ObjectStorage) String

func (x *ObjectStorage) String() string

type Queue

type Queue struct {
	NameServerAddr    string             `protobuf:"bytes,1,opt,name=name_server_addr,json=nameServerAddr,proto3" json:"name_server_addr,omitempty"`           // NameServer地址
	NameServerDomain  string             `protobuf:"bytes,2,opt,name=name_server_domain,json=nameServerDomain,proto3" json:"name_server_domain,omitempty"`     // NameServer域
	GroupName         string             `protobuf:"bytes,3,opt,name=group_name,json=groupName,proto3" json:"group_name,omitempty"`                            // 组名地址
	SendMsgTimeout    *duration.Duration `protobuf:"bytes,4,opt,name=send_msg_timeout,json=sendMsgTimeout,proto3" json:"send_msg_timeout,omitempty"`           // 发送消息超时时间
	WithCompressLevel uint32             `protobuf:"varint,5,opt,name=with_compress_level,json=withCompressLevel,proto3" json:"with_compress_level,omitempty"` // 设置压缩级别(0~9),0 代表最佳速度,9 代表最佳压缩比
	Retry             uint32             `protobuf:"varint,6,opt,name=retry,proto3" json:"retry,omitempty"`                                                    // 消费者失败重试次数
	DelayLevel        uint32             `protobuf:"varint,7,opt,name=delay_level,json=delayLevel,proto3" json:"delay_level,omitempty"`                        // 设置重新消费的延迟级别,共支持(0-18)种延迟级别
	// contains filtered or unexported fields
}

func (*Queue) Descriptor deprecated

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

Deprecated: Use Queue.ProtoReflect.Descriptor instead.

func (*Queue) GetDelayLevel

func (x *Queue) GetDelayLevel() uint32

func (*Queue) GetGroupName

func (x *Queue) GetGroupName() string

func (*Queue) GetNameServerAddr

func (x *Queue) GetNameServerAddr() string

func (*Queue) GetNameServerDomain

func (x *Queue) GetNameServerDomain() string

func (*Queue) GetRetry

func (x *Queue) GetRetry() uint32

func (*Queue) GetSendMsgTimeout

func (x *Queue) GetSendMsgTimeout() *duration.Duration

func (*Queue) GetWithCompressLevel

func (x *Queue) GetWithCompressLevel() uint32

func (*Queue) ProtoMessage

func (*Queue) ProtoMessage()

func (*Queue) ProtoReflect

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

func (*Queue) Reset

func (x *Queue) Reset()

func (*Queue) String

func (x *Queue) String() string

type Redis

type Redis struct {
	Network         string             `protobuf:"bytes,1,opt,name=network,proto3" json:"network,omitempty"`
	Addr            string             `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`
	Password        string             `protobuf:"bytes,3,opt,name=password,proto3" json:"password,omitempty"`
	ReadTimeout     *duration.Duration `protobuf:"bytes,4,opt,name=read_timeout,json=readTimeout,proto3" json:"read_timeout,omitempty"`
	WriteTimeout    *duration.Duration `protobuf:"bytes,5,opt,name=write_timeout,json=writeTimeout,proto3" json:"write_timeout,omitempty"`
	DelayDeleteTime *duration.Duration `protobuf:"bytes,6,opt,name=delay_delete_time,json=delayDeleteTime,proto3" json:"delay_delete_time,omitempty"`
	// contains filtered or unexported fields
}

func (*Redis) Descriptor deprecated

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

Deprecated: Use Redis.ProtoReflect.Descriptor instead.

func (*Redis) GetAddr

func (x *Redis) GetAddr() string

func (*Redis) GetDelayDeleteTime

func (x *Redis) GetDelayDeleteTime() *duration.Duration

func (*Redis) GetNetwork

func (x *Redis) GetNetwork() string

func (*Redis) GetPassword

func (x *Redis) GetPassword() string

func (*Redis) GetReadTimeout

func (x *Redis) GetReadTimeout() *duration.Duration

func (*Redis) GetWriteTimeout

func (x *Redis) GetWriteTimeout() *duration.Duration

func (*Redis) ProtoMessage

func (*Redis) ProtoMessage()

func (*Redis) ProtoReflect

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

func (*Redis) Reset

func (x *Redis) Reset()

func (*Redis) String

func (x *Redis) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL