Documentation ¶
Index ¶
- Variables
- type Bootstrap
- type Data
- func (*Data) Descriptor() ([]byte, []int)deprecated
- func (x *Data) GetDatabase() *Data_Database
- func (x *Data) GetKafka() *Data_Kafka
- func (x *Data) GetQueue() *Data_QueueMode
- func (x *Data) GetRedis() *Data_Redis
- func (x *Data) GetTasks() []*Data_TaskConfig
- func (*Data) ProtoMessage()
- func (x *Data) ProtoReflect() protoreflect.Message
- func (x *Data) Reset()
- func (x *Data) String() string
- type Data_Database
- func (*Data_Database) Descriptor() ([]byte, []int)deprecated
- func (x *Data_Database) GetDriver() string
- func (x *Data_Database) GetSource() string
- func (*Data_Database) ProtoMessage()
- func (x *Data_Database) ProtoReflect() protoreflect.Message
- func (x *Data_Database) Reset()
- func (x *Data_Database) String() string
- type Data_Kafka
- func (*Data_Kafka) Descriptor() ([]byte, []int)deprecated
- func (x *Data_Kafka) GetAddr() string
- func (x *Data_Kafka) GetPartition() int64
- func (x *Data_Kafka) GetTopics() []*Data_Kafka_Topic
- func (*Data_Kafka) ProtoMessage()
- func (x *Data_Kafka) ProtoReflect() protoreflect.Message
- func (x *Data_Kafka) Reset()
- func (x *Data_Kafka) String() string
- type Data_Kafka_Topic
- type Data_QueueMode
- type Data_Redis
- func (*Data_Redis) Descriptor() ([]byte, []int)deprecated
- func (x *Data_Redis) GetAddr() string
- func (x *Data_Redis) GetDb() int32
- func (x *Data_Redis) GetNetwork() string
- func (x *Data_Redis) GetPassword() string
- func (x *Data_Redis) GetReadTimeout() *durationpb.Duration
- func (x *Data_Redis) GetWriteTimeout() *durationpb.Duration
- func (*Data_Redis) ProtoMessage()
- func (x *Data_Redis) ProtoReflect() protoreflect.Message
- func (x *Data_Redis) Reset()
- func (x *Data_Redis) String() string
- type Data_TaskConfig
- func (*Data_TaskConfig) Descriptor() ([]byte, []int)deprecated
- func (x *Data_TaskConfig) GetCronExpr() string
- func (x *Data_TaskConfig) GetEnable() bool
- func (x *Data_TaskConfig) GetName() string
- func (*Data_TaskConfig) ProtoMessage()
- func (x *Data_TaskConfig) ProtoReflect() protoreflect.Message
- func (x *Data_TaskConfig) Reset()
- func (x *Data_TaskConfig) String() string
- type Server
- type Server_GRPC
- func (*Server_GRPC) Descriptor() ([]byte, []int)deprecated
- func (x *Server_GRPC) GetAddr() string
- func (x *Server_GRPC) GetNetwork() string
- func (x *Server_GRPC) GetTimeout() *durationpb.Duration
- func (*Server_GRPC) ProtoMessage()
- func (x *Server_GRPC) ProtoReflect() protoreflect.Message
- func (x *Server_GRPC) Reset()
- func (x *Server_GRPC) String() string
- type Server_HTTP
- func (*Server_HTTP) Descriptor() ([]byte, []int)deprecated
- func (x *Server_HTTP) GetAddr() string
- func (x *Server_HTTP) GetNetwork() string
- func (x *Server_HTTP) GetTimeout() *durationpb.Duration
- func (*Server_HTTP) ProtoMessage()
- func (x *Server_HTTP) ProtoReflect() protoreflect.Message
- func (x *Server_HTTP) Reset()
- func (x *Server_HTTP) String() string
Constants ¶
This section is empty.
Variables ¶
View Source
var File_conf_conf_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type Bootstrap ¶
type Bootstrap struct { Server *Server `protobuf:"bytes,1,opt,name=server,proto3" json:"server,omitempty"` Data *Data `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*Bootstrap) Descriptor
deprecated
func (*Bootstrap) ProtoMessage ¶
func (*Bootstrap) ProtoMessage()
func (*Bootstrap) ProtoReflect ¶
func (x *Bootstrap) ProtoReflect() protoreflect.Message
type Data ¶
type Data struct { Database *Data_Database `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"` Redis *Data_Redis `protobuf:"bytes,2,opt,name=redis,proto3" json:"redis,omitempty"` Kafka *Data_Kafka `protobuf:"bytes,3,opt,name=kafka,proto3" json:"kafka,omitempty"` Tasks []*Data_TaskConfig `protobuf:"bytes,4,rep,name=tasks,proto3" json:"tasks,omitempty"` Queue *Data_QueueMode `protobuf:"bytes,5,opt,name=queue,proto3" json:"queue,omitempty"` // contains filtered or unexported fields }
func (*Data) Descriptor
deprecated
func (*Data) GetDatabase ¶
func (x *Data) GetDatabase() *Data_Database
func (*Data) GetKafka ¶
func (x *Data) GetKafka() *Data_Kafka
func (*Data) GetQueue ¶
func (x *Data) GetQueue() *Data_QueueMode
func (*Data) GetRedis ¶
func (x *Data) GetRedis() *Data_Redis
func (*Data) GetTasks ¶
func (x *Data) GetTasks() []*Data_TaskConfig
func (*Data) ProtoMessage ¶
func (*Data) ProtoMessage()
func (*Data) ProtoReflect ¶
func (x *Data) ProtoReflect() protoreflect.Message
type Data_Database ¶
type Data_Database struct { Driver string `protobuf:"bytes,1,opt,name=driver,proto3" json:"driver,omitempty"` Source string `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"` // contains filtered or unexported fields }
func (*Data_Database) Descriptor
deprecated
func (*Data_Database) Descriptor() ([]byte, []int)
Deprecated: Use Data_Database.ProtoReflect.Descriptor instead.
func (*Data_Database) GetDriver ¶
func (x *Data_Database) GetDriver() string
func (*Data_Database) GetSource ¶
func (x *Data_Database) GetSource() string
func (*Data_Database) ProtoMessage ¶
func (*Data_Database) ProtoMessage()
func (*Data_Database) ProtoReflect ¶
func (x *Data_Database) ProtoReflect() protoreflect.Message
func (*Data_Database) Reset ¶
func (x *Data_Database) Reset()
func (*Data_Database) String ¶
func (x *Data_Database) String() string
type Data_Kafka ¶
type Data_Kafka struct { Addr string `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty"` Topics []*Data_Kafka_Topic `protobuf:"bytes,2,rep,name=topics,proto3" json:"topics,omitempty"` Partition int64 `protobuf:"varint,3,opt,name=partition,proto3" json:"partition,omitempty"` // contains filtered or unexported fields }
func (*Data_Kafka) Descriptor
deprecated
func (*Data_Kafka) Descriptor() ([]byte, []int)
Deprecated: Use Data_Kafka.ProtoReflect.Descriptor instead.
func (*Data_Kafka) GetAddr ¶
func (x *Data_Kafka) GetAddr() string
func (*Data_Kafka) GetPartition ¶
func (x *Data_Kafka) GetPartition() int64
func (*Data_Kafka) GetTopics ¶
func (x *Data_Kafka) GetTopics() []*Data_Kafka_Topic
func (*Data_Kafka) ProtoMessage ¶
func (*Data_Kafka) ProtoMessage()
func (*Data_Kafka) ProtoReflect ¶
func (x *Data_Kafka) ProtoReflect() protoreflect.Message
func (*Data_Kafka) Reset ¶
func (x *Data_Kafka) Reset()
func (*Data_Kafka) String ¶
func (x *Data_Kafka) String() string
type Data_Kafka_Topic ¶
type Data_Kafka_Topic struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
func (*Data_Kafka_Topic) Descriptor
deprecated
func (*Data_Kafka_Topic) Descriptor() ([]byte, []int)
Deprecated: Use Data_Kafka_Topic.ProtoReflect.Descriptor instead.
func (*Data_Kafka_Topic) GetName ¶
func (x *Data_Kafka_Topic) GetName() string
func (*Data_Kafka_Topic) ProtoMessage ¶
func (*Data_Kafka_Topic) ProtoMessage()
func (*Data_Kafka_Topic) ProtoReflect ¶
func (x *Data_Kafka_Topic) ProtoReflect() protoreflect.Message
func (*Data_Kafka_Topic) Reset ¶
func (x *Data_Kafka_Topic) Reset()
func (*Data_Kafka_Topic) String ¶
func (x *Data_Kafka_Topic) String() string
type Data_QueueMode ¶
type Data_QueueMode struct { Mode string `protobuf:"bytes,1,opt,name=mode,proto3" json:"mode,omitempty"` // contains filtered or unexported fields }
func (*Data_QueueMode) Descriptor
deprecated
func (*Data_QueueMode) Descriptor() ([]byte, []int)
Deprecated: Use Data_QueueMode.ProtoReflect.Descriptor instead.
func (*Data_QueueMode) GetMode ¶
func (x *Data_QueueMode) GetMode() string
func (*Data_QueueMode) ProtoMessage ¶
func (*Data_QueueMode) ProtoMessage()
func (*Data_QueueMode) ProtoReflect ¶
func (x *Data_QueueMode) ProtoReflect() protoreflect.Message
func (*Data_QueueMode) Reset ¶
func (x *Data_QueueMode) Reset()
func (*Data_QueueMode) String ¶
func (x *Data_QueueMode) String() string
type Data_Redis ¶
type Data_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"` ReadTimeout *durationpb.Duration `protobuf:"bytes,3,opt,name=read_timeout,json=readTimeout,proto3" json:"read_timeout,omitempty"` WriteTimeout *durationpb.Duration `protobuf:"bytes,4,opt,name=write_timeout,json=writeTimeout,proto3" json:"write_timeout,omitempty"` Db int32 `protobuf:"varint,5,opt,name=db,proto3" json:"db,omitempty"` Password string `protobuf:"bytes,6,opt,name=password,proto3" json:"password,omitempty"` // contains filtered or unexported fields }
func (*Data_Redis) Descriptor
deprecated
func (*Data_Redis) Descriptor() ([]byte, []int)
Deprecated: Use Data_Redis.ProtoReflect.Descriptor instead.
func (*Data_Redis) GetAddr ¶
func (x *Data_Redis) GetAddr() string
func (*Data_Redis) GetDb ¶
func (x *Data_Redis) GetDb() int32
func (*Data_Redis) GetNetwork ¶
func (x *Data_Redis) GetNetwork() string
func (*Data_Redis) GetPassword ¶
func (x *Data_Redis) GetPassword() string
func (*Data_Redis) GetReadTimeout ¶
func (x *Data_Redis) GetReadTimeout() *durationpb.Duration
func (*Data_Redis) GetWriteTimeout ¶
func (x *Data_Redis) GetWriteTimeout() *durationpb.Duration
func (*Data_Redis) ProtoMessage ¶
func (*Data_Redis) ProtoMessage()
func (*Data_Redis) ProtoReflect ¶
func (x *Data_Redis) ProtoReflect() protoreflect.Message
func (*Data_Redis) Reset ¶
func (x *Data_Redis) Reset()
func (*Data_Redis) String ¶
func (x *Data_Redis) String() string
type Data_TaskConfig ¶
type Data_TaskConfig struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` CronExpr string `protobuf:"bytes,2,opt,name=cron_expr,json=cronExpr,proto3" json:"cron_expr,omitempty"` Enable bool `protobuf:"varint,3,opt,name=enable,proto3" json:"enable,omitempty"` // contains filtered or unexported fields }
func (*Data_TaskConfig) Descriptor
deprecated
func (*Data_TaskConfig) Descriptor() ([]byte, []int)
Deprecated: Use Data_TaskConfig.ProtoReflect.Descriptor instead.
func (*Data_TaskConfig) GetCronExpr ¶
func (x *Data_TaskConfig) GetCronExpr() string
func (*Data_TaskConfig) GetEnable ¶
func (x *Data_TaskConfig) GetEnable() bool
func (*Data_TaskConfig) GetName ¶
func (x *Data_TaskConfig) GetName() string
func (*Data_TaskConfig) ProtoMessage ¶
func (*Data_TaskConfig) ProtoMessage()
func (*Data_TaskConfig) ProtoReflect ¶
func (x *Data_TaskConfig) ProtoReflect() protoreflect.Message
func (*Data_TaskConfig) Reset ¶
func (x *Data_TaskConfig) Reset()
func (*Data_TaskConfig) String ¶
func (x *Data_TaskConfig) String() string
type Server ¶
type Server struct { Http *Server_HTTP `protobuf:"bytes,1,opt,name=http,proto3" json:"http,omitempty"` Grpc *Server_GRPC `protobuf:"bytes,2,opt,name=grpc,proto3" json:"grpc,omitempty"` // contains filtered or unexported fields }
func (*Server) Descriptor
deprecated
func (*Server) GetGrpc ¶
func (x *Server) GetGrpc() *Server_GRPC
func (*Server) GetHttp ¶
func (x *Server) GetHttp() *Server_HTTP
func (*Server) ProtoMessage ¶
func (*Server) ProtoMessage()
func (*Server) ProtoReflect ¶
func (x *Server) ProtoReflect() protoreflect.Message
type Server_GRPC ¶
type Server_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 *durationpb.Duration `protobuf:"bytes,3,opt,name=timeout,proto3" json:"timeout,omitempty"` // contains filtered or unexported fields }
func (*Server_GRPC) Descriptor
deprecated
func (*Server_GRPC) Descriptor() ([]byte, []int)
Deprecated: Use Server_GRPC.ProtoReflect.Descriptor instead.
func (*Server_GRPC) GetAddr ¶
func (x *Server_GRPC) GetAddr() string
func (*Server_GRPC) GetNetwork ¶
func (x *Server_GRPC) GetNetwork() string
func (*Server_GRPC) GetTimeout ¶
func (x *Server_GRPC) GetTimeout() *durationpb.Duration
func (*Server_GRPC) ProtoMessage ¶
func (*Server_GRPC) ProtoMessage()
func (*Server_GRPC) ProtoReflect ¶
func (x *Server_GRPC) ProtoReflect() protoreflect.Message
func (*Server_GRPC) Reset ¶
func (x *Server_GRPC) Reset()
func (*Server_GRPC) String ¶
func (x *Server_GRPC) String() string
type Server_HTTP ¶
type Server_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 *durationpb.Duration `protobuf:"bytes,3,opt,name=timeout,proto3" json:"timeout,omitempty"` // contains filtered or unexported fields }
func (*Server_HTTP) Descriptor
deprecated
func (*Server_HTTP) Descriptor() ([]byte, []int)
Deprecated: Use Server_HTTP.ProtoReflect.Descriptor instead.
func (*Server_HTTP) GetAddr ¶
func (x *Server_HTTP) GetAddr() string
func (*Server_HTTP) GetNetwork ¶
func (x *Server_HTTP) GetNetwork() string
func (*Server_HTTP) GetTimeout ¶
func (x *Server_HTTP) GetTimeout() *durationpb.Duration
func (*Server_HTTP) ProtoMessage ¶
func (*Server_HTTP) ProtoMessage()
func (*Server_HTTP) ProtoReflect ¶
func (x *Server_HTTP) ProtoReflect() protoreflect.Message
func (*Server_HTTP) Reset ¶
func (x *Server_HTTP) Reset()
func (*Server_HTTP) String ¶
func (x *Server_HTTP) String() string
Click to show internal directories.
Click to hide internal directories.