job

Documentation

Index

• Variables
• type JobConfig
  • func (*JobConfig) Descriptor() ([]byte, []int)
  • func (x *JobConfig) GetAccessToken() string
  • func (x *JobConfig) GetEnabled() bool
  • func (x *JobConfig) GetExecutorIp() string
  • func (x *JobConfig) GetExecutorPort() int32
  • func (x *JobConfig) GetRegistryKey() string
  • func (x *JobConfig) GetServerAddr() string
  • func (x *JobConfig) GetTimeout() *durationpb.Duration
  • func (*JobConfig) ProtoMessage()
  • func (x *JobConfig) ProtoReflect() protoreflect.Message
  • func (x *JobConfig) Reset()
  • func (x *JobConfig) String() string

Variables

var File_job_job_proto protoreflect.FileDescriptor

Types

type JobConfig

type JobConfig struct {
	Enabled      bool                 `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"` // 执行器调度开关（是否允许调度执行）
	ServerAddr   string               `protobuf:"bytes,2,opt,name=server_addr,json=serverAddr,proto3" json:"server_addr,omitempty"`
	AccessToken  string               `protobuf:"bytes,3,opt,name=access_token,json=accessToken,proto3" json:"access_token,omitempty"`
	Timeout      *durationpb.Duration `protobuf:"bytes,4,opt,name=timeout,proto3" json:"timeout,omitempty"`
	ExecutorIp   *string              `protobuf:"bytes,5,opt,name=executor_ip,json=executorIp,proto3,oneof" json:"executor_ip,omitempty"`
	ExecutorPort *int32               `protobuf:"varint,6,opt,name=executor_port,json=executorPort,proto3,oneof" json:"executor_port,omitempty"`
	RegistryKey  *string              `protobuf:"bytes,7,opt,name=registry_key,json=registryKey,proto3,oneof" json:"registry_key,omitempty"`
	// contains filtered or unexported fields
}

func (*JobConfig) Descriptor

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

Deprecated: Use JobConfig.ProtoReflect.Descriptor instead.

func (*JobConfig) GetAccessToken

func (x *JobConfig) GetAccessToken() string

func (*JobConfig) GetEnabled

func (x *JobConfig) GetEnabled() bool

func (*JobConfig) GetExecutorIp

func (x *JobConfig) GetExecutorIp() string

func (*JobConfig) GetExecutorPort

func (x *JobConfig) GetExecutorPort() int32

func (*JobConfig) GetRegistryKey

func (x *JobConfig) GetRegistryKey() string

func (*JobConfig) GetServerAddr

func (x *JobConfig) GetServerAddr() string

func (*JobConfig) GetTimeout

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

func (*JobConfig) ProtoMessage

func (*JobConfig) ProtoMessage()

func (*JobConfig) ProtoReflect

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

func (*JobConfig) Reset

func (x *JobConfig) Reset()

func (*JobConfig) String

func (x *JobConfig) String() string