dkron: github.com/distribworks/dkron/proto Index | Files

package proto

import "github.com/distribworks/dkron/proto"

Index

Package Files

dkron.pb.go

func RegisterDkronServer Uses

func RegisterDkronServer(s *grpc.Server, srv DkronServer)

type DeleteJobRequest Uses

type DeleteJobRequest struct {
    JobName              string   `protobuf:"bytes,1,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*DeleteJobRequest) Descriptor Uses

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

func (*DeleteJobRequest) GetJobName Uses

func (m *DeleteJobRequest) GetJobName() string

func (*DeleteJobRequest) ProtoMessage Uses

func (*DeleteJobRequest) ProtoMessage()

func (*DeleteJobRequest) Reset Uses

func (m *DeleteJobRequest) Reset()

func (*DeleteJobRequest) String Uses

func (m *DeleteJobRequest) String() string

func (*DeleteJobRequest) XXX_DiscardUnknown Uses

func (m *DeleteJobRequest) XXX_DiscardUnknown()

func (*DeleteJobRequest) XXX_Marshal Uses

func (m *DeleteJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteJobRequest) XXX_Merge Uses

func (dst *DeleteJobRequest) XXX_Merge(src proto.Message)

func (*DeleteJobRequest) XXX_Size Uses

func (m *DeleteJobRequest) XXX_Size() int

func (*DeleteJobRequest) XXX_Unmarshal Uses

func (m *DeleteJobRequest) XXX_Unmarshal(b []byte) error

type DeleteJobResponse Uses

type DeleteJobResponse struct {
    Job                  *Job     `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*DeleteJobResponse) Descriptor Uses

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

func (*DeleteJobResponse) GetJob Uses

func (m *DeleteJobResponse) GetJob() *Job

func (*DeleteJobResponse) ProtoMessage Uses

func (*DeleteJobResponse) ProtoMessage()

func (*DeleteJobResponse) Reset Uses

func (m *DeleteJobResponse) Reset()

func (*DeleteJobResponse) String Uses

func (m *DeleteJobResponse) String() string

func (*DeleteJobResponse) XXX_DiscardUnknown Uses

func (m *DeleteJobResponse) XXX_DiscardUnknown()

func (*DeleteJobResponse) XXX_Marshal Uses

func (m *DeleteJobResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteJobResponse) XXX_Merge Uses

func (dst *DeleteJobResponse) XXX_Merge(src proto.Message)

func (*DeleteJobResponse) XXX_Size Uses

func (m *DeleteJobResponse) XXX_Size() int

func (*DeleteJobResponse) XXX_Unmarshal Uses

func (m *DeleteJobResponse) XXX_Unmarshal(b []byte) error

type DkronClient Uses

type DkronClient interface {
    GetJob(ctx context.Context, in *GetJobRequest, opts ...grpc.CallOption) (*GetJobResponse, error)
    ExecutionDone(ctx context.Context, in *ExecutionDoneRequest, opts ...grpc.CallOption) (*ExecutionDoneResponse, error)
    Leave(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*empty.Empty, error)
    SetJob(ctx context.Context, in *SetJobRequest, opts ...grpc.CallOption) (*SetJobResponse, error)
    DeleteJob(ctx context.Context, in *DeleteJobRequest, opts ...grpc.CallOption) (*DeleteJobResponse, error)
    RunJob(ctx context.Context, in *RunJobRequest, opts ...grpc.CallOption) (*RunJobResponse, error)
    ToggleJob(ctx context.Context, in *ToggleJobRequest, opts ...grpc.CallOption) (*ToggleJobResponse, error)
    RaftGetConfiguration(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*RaftGetConfigurationResponse, error)
    RaftRemovePeerByID(ctx context.Context, in *RaftRemovePeerByIDRequest, opts ...grpc.CallOption) (*empty.Empty, error)
}

DkronClient is the client API for Dkron service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewDkronClient Uses

func NewDkronClient(cc *grpc.ClientConn) DkronClient

type DkronServer Uses

type DkronServer interface {
    GetJob(context.Context, *GetJobRequest) (*GetJobResponse, error)
    ExecutionDone(context.Context, *ExecutionDoneRequest) (*ExecutionDoneResponse, error)
    Leave(context.Context, *empty.Empty) (*empty.Empty, error)
    SetJob(context.Context, *SetJobRequest) (*SetJobResponse, error)
    DeleteJob(context.Context, *DeleteJobRequest) (*DeleteJobResponse, error)
    RunJob(context.Context, *RunJobRequest) (*RunJobResponse, error)
    ToggleJob(context.Context, *ToggleJobRequest) (*ToggleJobResponse, error)
    RaftGetConfiguration(context.Context, *empty.Empty) (*RaftGetConfigurationResponse, error)
    RaftRemovePeerByID(context.Context, *RaftRemovePeerByIDRequest) (*empty.Empty, error)
}

DkronServer is the server API for Dkron service.

type Execution Uses

type Execution struct {
    JobName              string               `protobuf:"bytes,1,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
    Success              bool                 `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
    Output               []byte               `protobuf:"bytes,3,opt,name=output,proto3" json:"output,omitempty"`
    NodeName             string               `protobuf:"bytes,4,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"`
    Group                int64                `protobuf:"varint,5,opt,name=group,proto3" json:"group,omitempty"`
    Attempt              uint32               `protobuf:"varint,6,opt,name=attempt,proto3" json:"attempt,omitempty"`
    StartedAt            *timestamp.Timestamp `protobuf:"bytes,7,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
    FinishedAt           *timestamp.Timestamp `protobuf:"bytes,8,opt,name=finished_at,json=finishedAt,proto3" json:"finished_at,omitempty"`
    XXX_NoUnkeyedLiteral struct{}             `json:"-"`
    XXX_unrecognized     []byte               `json:"-"`
    XXX_sizecache        int32                `json:"-"`
}

func (*Execution) Descriptor Uses

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

func (*Execution) GetAttempt Uses

func (m *Execution) GetAttempt() uint32

func (*Execution) GetFinishedAt Uses

func (m *Execution) GetFinishedAt() *timestamp.Timestamp

func (*Execution) GetGroup Uses

func (m *Execution) GetGroup() int64

func (*Execution) GetJobName Uses

func (m *Execution) GetJobName() string

func (*Execution) GetNodeName Uses

func (m *Execution) GetNodeName() string

func (*Execution) GetOutput Uses

func (m *Execution) GetOutput() []byte

func (*Execution) GetStartedAt Uses

func (m *Execution) GetStartedAt() *timestamp.Timestamp

func (*Execution) GetSuccess Uses

func (m *Execution) GetSuccess() bool

func (*Execution) ProtoMessage Uses

func (*Execution) ProtoMessage()

func (*Execution) Reset Uses

func (m *Execution) Reset()

func (*Execution) String Uses

func (m *Execution) String() string

func (*Execution) XXX_DiscardUnknown Uses

func (m *Execution) XXX_DiscardUnknown()

func (*Execution) XXX_Marshal Uses

func (m *Execution) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Execution) XXX_Merge Uses

func (dst *Execution) XXX_Merge(src proto.Message)

func (*Execution) XXX_Size Uses

func (m *Execution) XXX_Size() int

func (*Execution) XXX_Unmarshal Uses

func (m *Execution) XXX_Unmarshal(b []byte) error

type ExecutionDoneRequest Uses

type ExecutionDoneRequest struct {
    Execution            *Execution `protobuf:"bytes,1,opt,name=execution,proto3" json:"execution,omitempty"`
    XXX_NoUnkeyedLiteral struct{}   `json:"-"`
    XXX_unrecognized     []byte     `json:"-"`
    XXX_sizecache        int32      `json:"-"`
}

func (*ExecutionDoneRequest) Descriptor Uses

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

func (*ExecutionDoneRequest) GetExecution Uses

func (m *ExecutionDoneRequest) GetExecution() *Execution

func (*ExecutionDoneRequest) ProtoMessage Uses

func (*ExecutionDoneRequest) ProtoMessage()

func (*ExecutionDoneRequest) Reset Uses

func (m *ExecutionDoneRequest) Reset()

func (*ExecutionDoneRequest) String Uses

func (m *ExecutionDoneRequest) String() string

func (*ExecutionDoneRequest) XXX_DiscardUnknown Uses

func (m *ExecutionDoneRequest) XXX_DiscardUnknown()

func (*ExecutionDoneRequest) XXX_Marshal Uses

func (m *ExecutionDoneRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExecutionDoneRequest) XXX_Merge Uses

func (dst *ExecutionDoneRequest) XXX_Merge(src proto.Message)

func (*ExecutionDoneRequest) XXX_Size Uses

func (m *ExecutionDoneRequest) XXX_Size() int

func (*ExecutionDoneRequest) XXX_Unmarshal Uses

func (m *ExecutionDoneRequest) XXX_Unmarshal(b []byte) error

type ExecutionDoneResponse Uses

type ExecutionDoneResponse struct {
    From                 string   `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
    Payload              []byte   `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*ExecutionDoneResponse) Descriptor Uses

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

func (*ExecutionDoneResponse) GetFrom Uses

func (m *ExecutionDoneResponse) GetFrom() string

func (*ExecutionDoneResponse) GetPayload Uses

func (m *ExecutionDoneResponse) GetPayload() []byte

func (*ExecutionDoneResponse) ProtoMessage Uses

func (*ExecutionDoneResponse) ProtoMessage()

func (*ExecutionDoneResponse) Reset Uses

func (m *ExecutionDoneResponse) Reset()

func (*ExecutionDoneResponse) String Uses

func (m *ExecutionDoneResponse) String() string

func (*ExecutionDoneResponse) XXX_DiscardUnknown Uses

func (m *ExecutionDoneResponse) XXX_DiscardUnknown()

func (*ExecutionDoneResponse) XXX_Marshal Uses

func (m *ExecutionDoneResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExecutionDoneResponse) XXX_Merge Uses

func (dst *ExecutionDoneResponse) XXX_Merge(src proto.Message)

func (*ExecutionDoneResponse) XXX_Size Uses

func (m *ExecutionDoneResponse) XXX_Size() int

func (*ExecutionDoneResponse) XXX_Unmarshal Uses

func (m *ExecutionDoneResponse) XXX_Unmarshal(b []byte) error

type Executions Uses

type Executions struct {
    Executions           []*Execution `protobuf:"bytes,1,rep,name=executions,proto3" json:"executions,omitempty"`
    XXX_NoUnkeyedLiteral struct{}     `json:"-"`
    XXX_unrecognized     []byte       `json:"-"`
    XXX_sizecache        int32        `json:"-"`
}

func (*Executions) Descriptor Uses

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

func (*Executions) GetExecutions Uses

func (m *Executions) GetExecutions() []*Execution

func (*Executions) ProtoMessage Uses

func (*Executions) ProtoMessage()

func (*Executions) Reset Uses

func (m *Executions) Reset()

func (*Executions) String Uses

func (m *Executions) String() string

func (*Executions) XXX_DiscardUnknown Uses

func (m *Executions) XXX_DiscardUnknown()

func (*Executions) XXX_Marshal Uses

func (m *Executions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Executions) XXX_Merge Uses

func (dst *Executions) XXX_Merge(src proto.Message)

func (*Executions) XXX_Size Uses

func (m *Executions) XXX_Size() int

func (*Executions) XXX_Unmarshal Uses

func (m *Executions) XXX_Unmarshal(b []byte) error

type GetJobRequest Uses

type GetJobRequest struct {
    JobName              string   `protobuf:"bytes,1,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*GetJobRequest) Descriptor Uses

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

func (*GetJobRequest) GetJobName Uses

func (m *GetJobRequest) GetJobName() string

func (*GetJobRequest) ProtoMessage Uses

func (*GetJobRequest) ProtoMessage()

func (*GetJobRequest) Reset Uses

func (m *GetJobRequest) Reset()

func (*GetJobRequest) String Uses

func (m *GetJobRequest) String() string

func (*GetJobRequest) XXX_DiscardUnknown Uses

func (m *GetJobRequest) XXX_DiscardUnknown()

func (*GetJobRequest) XXX_Marshal Uses

func (m *GetJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetJobRequest) XXX_Merge Uses

func (dst *GetJobRequest) XXX_Merge(src proto.Message)

func (*GetJobRequest) XXX_Size Uses

func (m *GetJobRequest) XXX_Size() int

func (*GetJobRequest) XXX_Unmarshal Uses

func (m *GetJobRequest) XXX_Unmarshal(b []byte) error

type GetJobResponse Uses

type GetJobResponse struct {
    Job                  *Job     `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*GetJobResponse) Descriptor Uses

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

func (*GetJobResponse) GetJob Uses

func (m *GetJobResponse) GetJob() *Job

func (*GetJobResponse) ProtoMessage Uses

func (*GetJobResponse) ProtoMessage()

func (*GetJobResponse) Reset Uses

func (m *GetJobResponse) Reset()

func (*GetJobResponse) String Uses

func (m *GetJobResponse) String() string

func (*GetJobResponse) XXX_DiscardUnknown Uses

func (m *GetJobResponse) XXX_DiscardUnknown()

func (*GetJobResponse) XXX_Marshal Uses

func (m *GetJobResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetJobResponse) XXX_Merge Uses

func (dst *GetJobResponse) XXX_Merge(src proto.Message)

func (*GetJobResponse) XXX_Size Uses

func (m *GetJobResponse) XXX_Size() int

func (*GetJobResponse) XXX_Unmarshal Uses

func (m *GetJobResponse) XXX_Unmarshal(b []byte) error

type Job Uses

type Job struct {
    Name                 string                   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
    Timezone             string                   `protobuf:"bytes,2,opt,name=timezone,proto3" json:"timezone,omitempty"`
    Schedule             string                   `protobuf:"bytes,3,opt,name=schedule,proto3" json:"schedule,omitempty"`
    Owner                string                   `protobuf:"bytes,7,opt,name=owner,proto3" json:"owner,omitempty"`
    OwnerEmail           string                   `protobuf:"bytes,8,opt,name=owner_email,json=ownerEmail,proto3" json:"owner_email,omitempty"`
    SuccessCount         int32                    `protobuf:"varint,9,opt,name=success_count,json=successCount,proto3" json:"success_count,omitempty"`
    ErrorCount           int32                    `protobuf:"varint,10,opt,name=error_count,json=errorCount,proto3" json:"error_count,omitempty"`
    Disabled             bool                     `protobuf:"varint,11,opt,name=disabled,proto3" json:"disabled,omitempty"`
    Tags                 map[string]string        `protobuf:"bytes,12,rep,name=tags,proto3" json:"tags,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    Retries              uint32                   `protobuf:"varint,13,opt,name=retries,proto3" json:"retries,omitempty"`
    DependentJobs        []string                 `protobuf:"bytes,14,rep,name=dependent_jobs,json=dependentJobs,proto3" json:"dependent_jobs,omitempty"`
    ParentJob            string                   `protobuf:"bytes,15,opt,name=parent_job,json=parentJob,proto3" json:"parent_job,omitempty"`
    Concurrency          string                   `protobuf:"bytes,16,opt,name=concurrency,proto3" json:"concurrency,omitempty"`
    Executor             string                   `protobuf:"bytes,17,opt,name=executor,proto3" json:"executor,omitempty"`
    ExecutorConfig       map[string]string        `protobuf:"bytes,18,rep,name=executor_config,json=executorConfig,proto3" json:"executor_config,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    Status               string                   `protobuf:"bytes,19,opt,name=status,proto3" json:"status,omitempty"`
    Metadata             map[string]string        `protobuf:"bytes,20,rep,name=metadata,proto3" json:"metadata,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    LastSuccess          *Job_NullableTime        `protobuf:"bytes,25,opt,name=last_success,json=lastSuccess,proto3" json:"last_success,omitempty"`
    LastError            *Job_NullableTime        `protobuf:"bytes,26,opt,name=last_error,json=lastError,proto3" json:"last_error,omitempty"`
    Next                 *timestamp.Timestamp     `protobuf:"bytes,23,opt,name=next,proto3" json:"next,omitempty"`
    Displayname          string                   `protobuf:"bytes,24,opt,name=displayname,proto3" json:"displayname,omitempty"`
    Processors           map[string]*PluginConfig `protobuf:"bytes,27,rep,name=processors,proto3" json:"processors,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
    XXX_unrecognized     []byte                   `json:"-"`
    XXX_sizecache        int32                    `json:"-"`
}

func (*Job) Descriptor Uses

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

func (*Job) GetConcurrency Uses

func (m *Job) GetConcurrency() string

func (*Job) GetDependentJobs Uses

func (m *Job) GetDependentJobs() []string

func (*Job) GetDisabled Uses

func (m *Job) GetDisabled() bool

func (*Job) GetDisplayname Uses

func (m *Job) GetDisplayname() string

func (*Job) GetErrorCount Uses

func (m *Job) GetErrorCount() int32

func (*Job) GetExecutor Uses

func (m *Job) GetExecutor() string

func (*Job) GetExecutorConfig Uses

func (m *Job) GetExecutorConfig() map[string]string

func (*Job) GetLastError Uses

func (m *Job) GetLastError() *Job_NullableTime

func (*Job) GetLastSuccess Uses

func (m *Job) GetLastSuccess() *Job_NullableTime

func (*Job) GetMetadata Uses

func (m *Job) GetMetadata() map[string]string

func (*Job) GetName Uses

func (m *Job) GetName() string

func (*Job) GetNext Uses

func (m *Job) GetNext() *timestamp.Timestamp

func (*Job) GetOwner Uses

func (m *Job) GetOwner() string

func (*Job) GetOwnerEmail Uses

func (m *Job) GetOwnerEmail() string

func (*Job) GetParentJob Uses

func (m *Job) GetParentJob() string

func (*Job) GetProcessors Uses

func (m *Job) GetProcessors() map[string]*PluginConfig

func (*Job) GetRetries Uses

func (m *Job) GetRetries() uint32

func (*Job) GetSchedule Uses

func (m *Job) GetSchedule() string

func (*Job) GetStatus Uses

func (m *Job) GetStatus() string

func (*Job) GetSuccessCount Uses

func (m *Job) GetSuccessCount() int32

func (*Job) GetTags Uses

func (m *Job) GetTags() map[string]string

func (*Job) GetTimezone Uses

func (m *Job) GetTimezone() string

func (*Job) ProtoMessage Uses

func (*Job) ProtoMessage()

func (*Job) Reset Uses

func (m *Job) Reset()

func (*Job) String Uses

func (m *Job) String() string

func (*Job) XXX_DiscardUnknown Uses

func (m *Job) XXX_DiscardUnknown()

func (*Job) XXX_Marshal Uses

func (m *Job) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Job) XXX_Merge Uses

func (dst *Job) XXX_Merge(src proto.Message)

func (*Job) XXX_Size Uses

func (m *Job) XXX_Size() int

func (*Job) XXX_Unmarshal Uses

func (m *Job) XXX_Unmarshal(b []byte) error

type Job_NullableTime Uses

type Job_NullableTime struct {
    HasValue             bool                 `protobuf:"varint,1,opt,name=has_value,json=hasValue,proto3" json:"has_value,omitempty"`
    Time                 *timestamp.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
    XXX_NoUnkeyedLiteral struct{}             `json:"-"`
    XXX_unrecognized     []byte               `json:"-"`
    XXX_sizecache        int32                `json:"-"`
}

func (*Job_NullableTime) Descriptor Uses

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

func (*Job_NullableTime) GetHasValue Uses

func (m *Job_NullableTime) GetHasValue() bool

func (*Job_NullableTime) GetTime Uses

func (m *Job_NullableTime) GetTime() *timestamp.Timestamp

func (*Job_NullableTime) ProtoMessage Uses

func (*Job_NullableTime) ProtoMessage()

func (*Job_NullableTime) Reset Uses

func (m *Job_NullableTime) Reset()

func (*Job_NullableTime) String Uses

func (m *Job_NullableTime) String() string

func (*Job_NullableTime) XXX_DiscardUnknown Uses

func (m *Job_NullableTime) XXX_DiscardUnknown()

func (*Job_NullableTime) XXX_Marshal Uses

func (m *Job_NullableTime) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Job_NullableTime) XXX_Merge Uses

func (dst *Job_NullableTime) XXX_Merge(src proto.Message)

func (*Job_NullableTime) XXX_Size Uses

func (m *Job_NullableTime) XXX_Size() int

func (*Job_NullableTime) XXX_Unmarshal Uses

func (m *Job_NullableTime) XXX_Unmarshal(b []byte) error

type PluginConfig Uses

type PluginConfig struct {
    Config               map[string]string `protobuf:"bytes,1,rep,name=config,proto3" json:"config,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    XXX_NoUnkeyedLiteral struct{}          `json:"-"`
    XXX_unrecognized     []byte            `json:"-"`
    XXX_sizecache        int32             `json:"-"`
}

func (*PluginConfig) Descriptor Uses

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

func (*PluginConfig) GetConfig Uses

func (m *PluginConfig) GetConfig() map[string]string

func (*PluginConfig) ProtoMessage Uses

func (*PluginConfig) ProtoMessage()

func (*PluginConfig) Reset Uses

func (m *PluginConfig) Reset()

func (*PluginConfig) String Uses

func (m *PluginConfig) String() string

func (*PluginConfig) XXX_DiscardUnknown Uses

func (m *PluginConfig) XXX_DiscardUnknown()

func (*PluginConfig) XXX_Marshal Uses

func (m *PluginConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PluginConfig) XXX_Merge Uses

func (dst *PluginConfig) XXX_Merge(src proto.Message)

func (*PluginConfig) XXX_Size Uses

func (m *PluginConfig) XXX_Size() int

func (*PluginConfig) XXX_Unmarshal Uses

func (m *PluginConfig) XXX_Unmarshal(b []byte) error

type RaftGetConfigurationResponse Uses

type RaftGetConfigurationResponse struct {
    Servers              []*RaftServer `protobuf:"bytes,1,rep,name=servers,proto3" json:"servers,omitempty"`
    Index                uint64        `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"`
    XXX_NoUnkeyedLiteral struct{}      `json:"-"`
    XXX_unrecognized     []byte        `json:"-"`
    XXX_sizecache        int32         `json:"-"`
}

func (*RaftGetConfigurationResponse) Descriptor Uses

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

func (*RaftGetConfigurationResponse) GetIndex Uses

func (m *RaftGetConfigurationResponse) GetIndex() uint64

func (*RaftGetConfigurationResponse) GetServers Uses

func (m *RaftGetConfigurationResponse) GetServers() []*RaftServer

func (*RaftGetConfigurationResponse) ProtoMessage Uses

func (*RaftGetConfigurationResponse) ProtoMessage()

func (*RaftGetConfigurationResponse) Reset Uses

func (m *RaftGetConfigurationResponse) Reset()

func (*RaftGetConfigurationResponse) String Uses

func (m *RaftGetConfigurationResponse) String() string

func (*RaftGetConfigurationResponse) XXX_DiscardUnknown Uses

func (m *RaftGetConfigurationResponse) XXX_DiscardUnknown()

func (*RaftGetConfigurationResponse) XXX_Marshal Uses

func (m *RaftGetConfigurationResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RaftGetConfigurationResponse) XXX_Merge Uses

func (dst *RaftGetConfigurationResponse) XXX_Merge(src proto.Message)

func (*RaftGetConfigurationResponse) XXX_Size Uses

func (m *RaftGetConfigurationResponse) XXX_Size() int

func (*RaftGetConfigurationResponse) XXX_Unmarshal Uses

func (m *RaftGetConfigurationResponse) XXX_Unmarshal(b []byte) error

type RaftRemovePeerByIDRequest Uses

type RaftRemovePeerByIDRequest struct {
    Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*RaftRemovePeerByIDRequest) Descriptor Uses

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

func (*RaftRemovePeerByIDRequest) GetId Uses

func (m *RaftRemovePeerByIDRequest) GetId() string

func (*RaftRemovePeerByIDRequest) ProtoMessage Uses

func (*RaftRemovePeerByIDRequest) ProtoMessage()

func (*RaftRemovePeerByIDRequest) Reset Uses

func (m *RaftRemovePeerByIDRequest) Reset()

func (*RaftRemovePeerByIDRequest) String Uses

func (m *RaftRemovePeerByIDRequest) String() string

func (*RaftRemovePeerByIDRequest) XXX_DiscardUnknown Uses

func (m *RaftRemovePeerByIDRequest) XXX_DiscardUnknown()

func (*RaftRemovePeerByIDRequest) XXX_Marshal Uses

func (m *RaftRemovePeerByIDRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RaftRemovePeerByIDRequest) XXX_Merge Uses

func (dst *RaftRemovePeerByIDRequest) XXX_Merge(src proto.Message)

func (*RaftRemovePeerByIDRequest) XXX_Size Uses

func (m *RaftRemovePeerByIDRequest) XXX_Size() int

func (*RaftRemovePeerByIDRequest) XXX_Unmarshal Uses

func (m *RaftRemovePeerByIDRequest) XXX_Unmarshal(b []byte) error

type RaftServer Uses

type RaftServer struct {
    Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
    Node                 string   `protobuf:"bytes,2,opt,name=node,proto3" json:"node,omitempty"`
    Address              string   `protobuf:"bytes,3,opt,name=address,proto3" json:"address,omitempty"`
    Leader               bool     `protobuf:"varint,4,opt,name=leader,proto3" json:"leader,omitempty"`
    Voter                bool     `protobuf:"varint,5,opt,name=voter,proto3" json:"voter,omitempty"`
    RaftProtocol         string   `protobuf:"bytes,6,opt,name=raft_protocol,json=raftProtocol,proto3" json:"raft_protocol,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*RaftServer) Descriptor Uses

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

func (*RaftServer) GetAddress Uses

func (m *RaftServer) GetAddress() string

func (*RaftServer) GetId Uses

func (m *RaftServer) GetId() string

func (*RaftServer) GetLeader Uses

func (m *RaftServer) GetLeader() bool

func (*RaftServer) GetNode Uses

func (m *RaftServer) GetNode() string

func (*RaftServer) GetRaftProtocol Uses

func (m *RaftServer) GetRaftProtocol() string

func (*RaftServer) GetVoter Uses

func (m *RaftServer) GetVoter() bool

func (*RaftServer) ProtoMessage Uses

func (*RaftServer) ProtoMessage()

func (*RaftServer) Reset Uses

func (m *RaftServer) Reset()

func (*RaftServer) String Uses

func (m *RaftServer) String() string

func (*RaftServer) XXX_DiscardUnknown Uses

func (m *RaftServer) XXX_DiscardUnknown()

func (*RaftServer) XXX_Marshal Uses

func (m *RaftServer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RaftServer) XXX_Merge Uses

func (dst *RaftServer) XXX_Merge(src proto.Message)

func (*RaftServer) XXX_Size Uses

func (m *RaftServer) XXX_Size() int

func (*RaftServer) XXX_Unmarshal Uses

func (m *RaftServer) XXX_Unmarshal(b []byte) error

type RunJobRequest Uses

type RunJobRequest struct {
    JobName              string   `protobuf:"bytes,1,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*RunJobRequest) Descriptor Uses

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

func (*RunJobRequest) GetJobName Uses

func (m *RunJobRequest) GetJobName() string

func (*RunJobRequest) ProtoMessage Uses

func (*RunJobRequest) ProtoMessage()

func (*RunJobRequest) Reset Uses

func (m *RunJobRequest) Reset()

func (*RunJobRequest) String Uses

func (m *RunJobRequest) String() string

func (*RunJobRequest) XXX_DiscardUnknown Uses

func (m *RunJobRequest) XXX_DiscardUnknown()

func (*RunJobRequest) XXX_Marshal Uses

func (m *RunJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RunJobRequest) XXX_Merge Uses

func (dst *RunJobRequest) XXX_Merge(src proto.Message)

func (*RunJobRequest) XXX_Size Uses

func (m *RunJobRequest) XXX_Size() int

func (*RunJobRequest) XXX_Unmarshal Uses

func (m *RunJobRequest) XXX_Unmarshal(b []byte) error

type RunJobResponse Uses

type RunJobResponse struct {
    Job                  *Job     `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*RunJobResponse) Descriptor Uses

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

func (*RunJobResponse) GetJob Uses

func (m *RunJobResponse) GetJob() *Job

func (*RunJobResponse) ProtoMessage Uses

func (*RunJobResponse) ProtoMessage()

func (*RunJobResponse) Reset Uses

func (m *RunJobResponse) Reset()

func (*RunJobResponse) String Uses

func (m *RunJobResponse) String() string

func (*RunJobResponse) XXX_DiscardUnknown Uses

func (m *RunJobResponse) XXX_DiscardUnknown()

func (*RunJobResponse) XXX_Marshal Uses

func (m *RunJobResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RunJobResponse) XXX_Merge Uses

func (dst *RunJobResponse) XXX_Merge(src proto.Message)

func (*RunJobResponse) XXX_Size Uses

func (m *RunJobResponse) XXX_Size() int

func (*RunJobResponse) XXX_Unmarshal Uses

func (m *RunJobResponse) XXX_Unmarshal(b []byte) error

type SetJobRequest Uses

type SetJobRequest struct {
    Job                  *Job     `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*SetJobRequest) Descriptor Uses

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

func (*SetJobRequest) GetJob Uses

func (m *SetJobRequest) GetJob() *Job

func (*SetJobRequest) ProtoMessage Uses

func (*SetJobRequest) ProtoMessage()

func (*SetJobRequest) Reset Uses

func (m *SetJobRequest) Reset()

func (*SetJobRequest) String Uses

func (m *SetJobRequest) String() string

func (*SetJobRequest) XXX_DiscardUnknown Uses

func (m *SetJobRequest) XXX_DiscardUnknown()

func (*SetJobRequest) XXX_Marshal Uses

func (m *SetJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SetJobRequest) XXX_Merge Uses

func (dst *SetJobRequest) XXX_Merge(src proto.Message)

func (*SetJobRequest) XXX_Size Uses

func (m *SetJobRequest) XXX_Size() int

func (*SetJobRequest) XXX_Unmarshal Uses

func (m *SetJobRequest) XXX_Unmarshal(b []byte) error

type SetJobResponse Uses

type SetJobResponse struct {
    Job                  *Job     `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*SetJobResponse) Descriptor Uses

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

func (*SetJobResponse) GetJob Uses

func (m *SetJobResponse) GetJob() *Job

func (*SetJobResponse) ProtoMessage Uses

func (*SetJobResponse) ProtoMessage()

func (*SetJobResponse) Reset Uses

func (m *SetJobResponse) Reset()

func (*SetJobResponse) String Uses

func (m *SetJobResponse) String() string

func (*SetJobResponse) XXX_DiscardUnknown Uses

func (m *SetJobResponse) XXX_DiscardUnknown()

func (*SetJobResponse) XXX_Marshal Uses

func (m *SetJobResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SetJobResponse) XXX_Merge Uses

func (dst *SetJobResponse) XXX_Merge(src proto.Message)

func (*SetJobResponse) XXX_Size Uses

func (m *SetJobResponse) XXX_Size() int

func (*SetJobResponse) XXX_Unmarshal Uses

func (m *SetJobResponse) XXX_Unmarshal(b []byte) error

type ToggleJobRequest Uses

type ToggleJobRequest struct {
    JobName              string   `protobuf:"bytes,1,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*ToggleJobRequest) Descriptor Uses

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

func (*ToggleJobRequest) GetJobName Uses

func (m *ToggleJobRequest) GetJobName() string

func (*ToggleJobRequest) ProtoMessage Uses

func (*ToggleJobRequest) ProtoMessage()

func (*ToggleJobRequest) Reset Uses

func (m *ToggleJobRequest) Reset()

func (*ToggleJobRequest) String Uses

func (m *ToggleJobRequest) String() string

func (*ToggleJobRequest) XXX_DiscardUnknown Uses

func (m *ToggleJobRequest) XXX_DiscardUnknown()

func (*ToggleJobRequest) XXX_Marshal Uses

func (m *ToggleJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ToggleJobRequest) XXX_Merge Uses

func (dst *ToggleJobRequest) XXX_Merge(src proto.Message)

func (*ToggleJobRequest) XXX_Size Uses

func (m *ToggleJobRequest) XXX_Size() int

func (*ToggleJobRequest) XXX_Unmarshal Uses

func (m *ToggleJobRequest) XXX_Unmarshal(b []byte) error

type ToggleJobResponse Uses

type ToggleJobResponse struct {
    Job                  *Job     `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*ToggleJobResponse) Descriptor Uses

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

func (*ToggleJobResponse) GetJob Uses

func (m *ToggleJobResponse) GetJob() *Job

func (*ToggleJobResponse) ProtoMessage Uses

func (*ToggleJobResponse) ProtoMessage()

func (*ToggleJobResponse) Reset Uses

func (m *ToggleJobResponse) Reset()

func (*ToggleJobResponse) String Uses

func (m *ToggleJobResponse) String() string

func (*ToggleJobResponse) XXX_DiscardUnknown Uses

func (m *ToggleJobResponse) XXX_DiscardUnknown()

func (*ToggleJobResponse) XXX_Marshal Uses

func (m *ToggleJobResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ToggleJobResponse) XXX_Merge Uses

func (dst *ToggleJobResponse) XXX_Merge(src proto.Message)

func (*ToggleJobResponse) XXX_Size Uses

func (m *ToggleJobResponse) XXX_Size() int

func (*ToggleJobResponse) XXX_Unmarshal Uses

func (m *ToggleJobResponse) XXX_Unmarshal(b []byte) error

Package proto imports 7 packages (graph) and is imported by 1 packages. Updated 2019-11-12. Refresh now. Tools for package owners.