drlm

package
v0.0.0-...-0325488 Latest Latest
Warning

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

 Go to latest Published: Jun 5, 2020 License: AGPL-3.0 Imports: 8 Imported by: 8

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var AgentConnectionFromAgent_MessageType_name = map[int32]string{
	0: "MESSAGE_TYPE_UNKNOWN",
	1: "MESSAGE_TYPE_JOIN_REQUEST",
	2: "MESSAGE_TYPE_CONN_ESTABLISH",
	3: "MESSAGE_TYPE_JOB_UPDATE",
}
View Source 
var AgentConnectionFromAgent_MessageType_value = map[string]int32{
	"MESSAGE_TYPE_UNKNOWN":        0,
	"MESSAGE_TYPE_JOIN_REQUEST":   1,
	"MESSAGE_TYPE_CONN_ESTABLISH": 2,
	"MESSAGE_TYPE_JOB_UPDATE":     3,
}
View Source 
var AgentConnectionFromCore_JoinResponse_Status_name = map[int32]string{
	0: "STATUS_UNKNOWN",
	1: "STATUS_ACCEPT",
	2: "STATUS_REJECT",
}
View Source 
var AgentConnectionFromCore_JoinResponse_Status_value = map[string]int32{
	"STATUS_UNKNOWN": 0,
	"STATUS_ACCEPT":  1,
	"STATUS_REJECT":  2,
}
View Source 
var AgentConnectionFromCore_MessageType_name = map[int32]string{
	0: "MESSAGE_TYPE_UNKNOWN",
	1: "MESSAGE_TYPE_JOIN_RESPONSE",
	2: "MESSAGE_TYPE_JOB_NEW",
	3: "MESSAGE_TYPE_JOB_CANCEL",
	4: "MESSAGE_TYPE_INSTALL_BINARY",
}
View Source 
var AgentConnectionFromCore_MessageType_value = map[string]int32{
	"MESSAGE_TYPE_UNKNOWN":        0,
	"MESSAGE_TYPE_JOIN_RESPONSE":  1,
	"MESSAGE_TYPE_JOB_NEW":        2,
	"MESSAGE_TYPE_JOB_CANCEL":     3,
	"MESSAGE_TYPE_INSTALL_BINARY": 4,
}
View Source 
var AgentInstallResponse_Code_name = map[int32]string{
	0: "UNKNOWN",
	1: "OK",
	2: "FAILED",
}
View Source 
var AgentInstallResponse_Code_value = map[string]int32{
	"UNKNOWN": 0,
	"OK":      1,
	"FAILED":  2,
}
View Source 
var Arch_name = map[int32]string{
	0: "ARCH_UNKNOWN",
	1: "ARCH_AMD64",
}
View Source 
var Arch_value = map[string]int32{
	"ARCH_UNKNOWN": 0,
	"ARCH_AMD64":   1,
}
View Source 
var AuthType_name = map[int32]string{
	0: "AUTH_UNKNOWN",
	1: "AUTH_LOCAL",
}
View Source 
var AuthType_value = map[string]int32{
	"AUTH_UNKNOWN": 0,
	"AUTH_LOCAL":   1,
}
View Source 
var JobStatus_name = map[int32]string{
	0: "JOB_STATUS_UNKNOWN",
	1: "JOB_STATUS_SCHEDULED",
	2: "JOB_STATUS_RUNNING",
	3: "JOB_STATUS_FINISHED",
	4: "JOB_STATUS_FAILED",
	5: "JOB_STATUS_CANCELLED",
}
View Source 
var JobStatus_value = map[string]int32{
	"JOB_STATUS_UNKNOWN":   0,
	"JOB_STATUS_SCHEDULED": 1,
	"JOB_STATUS_RUNNING":   2,
	"JOB_STATUS_FINISHED":  3,
	"JOB_STATUS_FAILED":    4,
	"JOB_STATUS_CANCELLED": 5,
}
View Source 
var OS_name = map[int32]string{
	0:  "OS_UNKNOWN",
	1:  "OS_LINUX",
	2:  "OS_WINDOWS",
	3:  "OS_DARWIN",
	4:  "OS_AIX",
	5:  "OS_DRAGONFLY",
	6:  "OS_FREEBSD",
	7:  "OS_NETBSD",
	8:  "OS_OPENBSD",
	9:  "OS_PLAN9",
	10: "OS_SOLARIS",
}
View Source 
var OS_value = map[string]int32{
	"OS_UNKNOWN":   0,
	"OS_LINUX":     1,
	"OS_WINDOWS":   2,
	"OS_DARWIN":    3,
	"OS_AIX":       4,
	"OS_DRAGONFLY": 5,
	"OS_FREEBSD":   6,
	"OS_NETBSD":    7,
	"OS_OPENBSD":   8,
	"OS_PLAN9":     9,
	"OS_SOLARIS":   10,
}

Functions

func RegisterDRLMServer 

func RegisterDRLMServer(s *grpc.Server, srv DRLMServer)

Types

type AgentAcceptRequest 

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

func (*AgentAcceptRequest) Descriptor 

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

func (*AgentAcceptRequest) GetHost 

func (m *AgentAcceptRequest) GetHost() string

func (*AgentAcceptRequest) ProtoMessage 

func (*AgentAcceptRequest) ProtoMessage()

func (*AgentAcceptRequest) Reset 

func (m *AgentAcceptRequest) Reset()

func (*AgentAcceptRequest) String 

func (m *AgentAcceptRequest) String() string

func (*AgentAcceptRequest) XXX_DiscardUnknown 

func (m *AgentAcceptRequest) XXX_DiscardUnknown()

func (*AgentAcceptRequest) XXX_Marshal 

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

func (*AgentAcceptRequest) XXX_Merge 

func (m *AgentAcceptRequest) XXX_Merge(src proto.Message)

func (*AgentAcceptRequest) XXX_Size 

func (m *AgentAcceptRequest) XXX_Size() int

func (*AgentAcceptRequest) XXX_Unmarshal 

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

type AgentAcceptResponse 

type AgentAcceptResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AgentAcceptResponse) Descriptor 

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

func (*AgentAcceptResponse) ProtoMessage 

func (*AgentAcceptResponse) ProtoMessage()

func (*AgentAcceptResponse) Reset 

func (m *AgentAcceptResponse) Reset()

func (*AgentAcceptResponse) String 

func (m *AgentAcceptResponse) String() string

func (*AgentAcceptResponse) XXX_DiscardUnknown 

func (m *AgentAcceptResponse) XXX_DiscardUnknown()

func (*AgentAcceptResponse) XXX_Marshal 

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

func (*AgentAcceptResponse) XXX_Merge 

func (m *AgentAcceptResponse) XXX_Merge(src proto.Message)

func (*AgentAcceptResponse) XXX_Size 

func (m *AgentAcceptResponse) XXX_Size() int

func (*AgentAcceptResponse) XXX_Unmarshal 

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

type AgentAddRequest 

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

func (*AgentAddRequest) Descriptor 

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

func (*AgentAddRequest) GetHost 

func (m *AgentAddRequest) GetHost() string

func (*AgentAddRequest) ProtoMessage 

func (*AgentAddRequest) ProtoMessage()

func (*AgentAddRequest) Reset 

func (m *AgentAddRequest) Reset()

func (*AgentAddRequest) String 

func (m *AgentAddRequest) String() string

func (*AgentAddRequest) XXX_DiscardUnknown 

func (m *AgentAddRequest) XXX_DiscardUnknown()

func (*AgentAddRequest) XXX_Marshal 

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

func (*AgentAddRequest) XXX_Merge 

func (m *AgentAddRequest) XXX_Merge(src proto.Message)

func (*AgentAddRequest) XXX_Size 

func (m *AgentAddRequest) XXX_Size() int

func (*AgentAddRequest) XXX_Unmarshal 

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

type AgentAddResponse 

type AgentAddResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AgentAddResponse) Descriptor 

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

func (*AgentAddResponse) ProtoMessage 

func (*AgentAddResponse) ProtoMessage()

func (*AgentAddResponse) Reset 

func (m *AgentAddResponse) Reset()

func (*AgentAddResponse) String 

func (m *AgentAddResponse) String() string

func (*AgentAddResponse) XXX_DiscardUnknown 

func (m *AgentAddResponse) XXX_DiscardUnknown()

func (*AgentAddResponse) XXX_Marshal 

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

func (*AgentAddResponse) XXX_Merge 

func (m *AgentAddResponse) XXX_Merge(src proto.Message)

func (*AgentAddResponse) XXX_Size 

func (m *AgentAddResponse) XXX_Size() int

func (*AgentAddResponse) XXX_Unmarshal 

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

type AgentConnectionFromAgent 

type AgentConnectionFromAgent struct {
	MessageType          AgentConnectionFromAgent_MessageType  `` /* 142-byte string literal not displayed */
	JoinRequest          *AgentConnectionFromAgent_JoinRequest `protobuf:"bytes,2,opt,name=join_request,json=joinRequest,proto3" json:"join_request,omitempty"`
	JobUpdate            *AgentConnectionFromAgent_JobUpdate   `protobuf:"bytes,3,opt,name=job_update,json=jobUpdate,proto3" json:"job_update,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                              `json:"-"`
	XXX_unrecognized     []byte                                `json:"-"`
	XXX_sizecache        int32                                 `json:"-"`
}

func (*AgentConnectionFromAgent) Descriptor 

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

func (*AgentConnectionFromAgent) GetJobUpdate 

func (m *AgentConnectionFromAgent) GetJobUpdate() *AgentConnectionFromAgent_JobUpdate

func (*AgentConnectionFromAgent) GetJoinRequest 

func (m *AgentConnectionFromAgent) GetJoinRequest() *AgentConnectionFromAgent_JoinRequest

func (*AgentConnectionFromAgent) GetMessageType 

func (m *AgentConnectionFromAgent) GetMessageType() AgentConnectionFromAgent_MessageType

func (*AgentConnectionFromAgent) ProtoMessage 

func (*AgentConnectionFromAgent) ProtoMessage()

func (*AgentConnectionFromAgent) Reset 

func (m *AgentConnectionFromAgent) Reset()

func (*AgentConnectionFromAgent) String 

func (m *AgentConnectionFromAgent) String() string

func (*AgentConnectionFromAgent) XXX_DiscardUnknown 

func (m *AgentConnectionFromAgent) XXX_DiscardUnknown()

func (*AgentConnectionFromAgent) XXX_Marshal 

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

func (*AgentConnectionFromAgent) XXX_Merge 

func (m *AgentConnectionFromAgent) XXX_Merge(src proto.Message)

func (*AgentConnectionFromAgent) XXX_Size 

func (m *AgentConnectionFromAgent) XXX_Size() int

func (*AgentConnectionFromAgent) XXX_Unmarshal 

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

type AgentConnectionFromAgent_JobUpdate 

type AgentConnectionFromAgent_JobUpdate struct {
	JobId                uint32    `protobuf:"varint,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	Status               JobStatus `protobuf:"varint,2,opt,name=status,proto3,enum=drlm.JobStatus" json:"status,omitempty"`
	Info                 string    `protobuf:"bytes,3,opt,name=info,proto3" json:"info,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*AgentConnectionFromAgent_JobUpdate) Descriptor 

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

func (*AgentConnectionFromAgent_JobUpdate) GetInfo 

func (m *AgentConnectionFromAgent_JobUpdate) GetInfo() string

func (*AgentConnectionFromAgent_JobUpdate) GetJobId 

func (m *AgentConnectionFromAgent_JobUpdate) GetJobId() uint32

func (*AgentConnectionFromAgent_JobUpdate) GetStatus 

func (m *AgentConnectionFromAgent_JobUpdate) GetStatus() JobStatus

func (*AgentConnectionFromAgent_JobUpdate) ProtoMessage 

func (*AgentConnectionFromAgent_JobUpdate) ProtoMessage()

func (*AgentConnectionFromAgent_JobUpdate) Reset 

func (m *AgentConnectionFromAgent_JobUpdate) Reset()

func (*AgentConnectionFromAgent_JobUpdate) String 

func (m *AgentConnectionFromAgent_JobUpdate) String() string

func (*AgentConnectionFromAgent_JobUpdate) XXX_DiscardUnknown 

func (m *AgentConnectionFromAgent_JobUpdate) XXX_DiscardUnknown()

func (*AgentConnectionFromAgent_JobUpdate) XXX_Marshal 

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

func (*AgentConnectionFromAgent_JobUpdate) XXX_Merge 

func (m *AgentConnectionFromAgent_JobUpdate) XXX_Merge(src proto.Message)

func (*AgentConnectionFromAgent_JobUpdate) XXX_Size 

func (m *AgentConnectionFromAgent_JobUpdate) XXX_Size() int

func (*AgentConnectionFromAgent_JobUpdate) XXX_Unmarshal 

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

type AgentConnectionFromAgent_JoinRequest 

type AgentConnectionFromAgent_JoinRequest struct {
	Arch                 Arch     `protobuf:"varint,1,opt,name=arch,proto3,enum=drlm.Arch" json:"arch,omitempty"`
	Os                   OS       `protobuf:"varint,2,opt,name=os,proto3,enum=drlm.OS" json:"os,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AgentConnectionFromAgent_JoinRequest) Descriptor 

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

func (*AgentConnectionFromAgent_JoinRequest) GetArch 

func (m *AgentConnectionFromAgent_JoinRequest) GetArch() Arch

func (*AgentConnectionFromAgent_JoinRequest) GetOs 

func (m *AgentConnectionFromAgent_JoinRequest) GetOs() OS

func (*AgentConnectionFromAgent_JoinRequest) ProtoMessage 

func (*AgentConnectionFromAgent_JoinRequest) ProtoMessage()

func (*AgentConnectionFromAgent_JoinRequest) Reset 

func (m *AgentConnectionFromAgent_JoinRequest) Reset()

func (*AgentConnectionFromAgent_JoinRequest) String 

func (m *AgentConnectionFromAgent_JoinRequest) String() string

func (*AgentConnectionFromAgent_JoinRequest) XXX_DiscardUnknown 

func (m *AgentConnectionFromAgent_JoinRequest) XXX_DiscardUnknown()

func (*AgentConnectionFromAgent_JoinRequest) XXX_Marshal 

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

func (*AgentConnectionFromAgent_JoinRequest) XXX_Merge 

func (m *AgentConnectionFromAgent_JoinRequest) XXX_Merge(src proto.Message)

func (*AgentConnectionFromAgent_JoinRequest) XXX_Size 

func (m *AgentConnectionFromAgent_JoinRequest) XXX_Size() int

func (*AgentConnectionFromAgent_JoinRequest) XXX_Unmarshal 

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

type AgentConnectionFromAgent_MessageType 

type AgentConnectionFromAgent_MessageType int32
const (
	AgentConnectionFromAgent_MESSAGE_TYPE_UNKNOWN        AgentConnectionFromAgent_MessageType = 0
	AgentConnectionFromAgent_MESSAGE_TYPE_JOIN_REQUEST   AgentConnectionFromAgent_MessageType = 1
	AgentConnectionFromAgent_MESSAGE_TYPE_CONN_ESTABLISH AgentConnectionFromAgent_MessageType = 2
	AgentConnectionFromAgent_MESSAGE_TYPE_JOB_UPDATE     AgentConnectionFromAgent_MessageType = 3
)

func (AgentConnectionFromAgent_MessageType) EnumDescriptor 

func (AgentConnectionFromAgent_MessageType) EnumDescriptor() ([]byte, []int)

func (AgentConnectionFromAgent_MessageType) String 

func (x AgentConnectionFromAgent_MessageType) String() string

type AgentConnectionFromCore 

type AgentConnectionFromCore struct {
	MessageType          AgentConnectionFromCore_MessageType    `` /* 141-byte string literal not displayed */
	JoinResponse         *AgentConnectionFromCore_JoinResponse  `protobuf:"bytes,2,opt,name=join_response,json=joinResponse,proto3" json:"join_response,omitempty"`
	JobNew               *AgentConnectionFromCore_JobNew        `protobuf:"bytes,3,opt,name=job_new,json=jobNew,proto3" json:"job_new,omitempty"`
	JobCancel            *AgentConnectionFromCore_JobCancel     `protobuf:"bytes,4,opt,name=job_cancel,json=jobCancel,proto3" json:"job_cancel,omitempty"`
	InstallBinary        *AgentConnectionFromCore_InstallBinary `protobuf:"bytes,5,opt,name=install_binary,json=installBinary,proto3" json:"install_binary,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                               `json:"-"`
	XXX_unrecognized     []byte                                 `json:"-"`
	XXX_sizecache        int32                                  `json:"-"`
}

func (*AgentConnectionFromCore) Descriptor 

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

func (*AgentConnectionFromCore) GetInstallBinary 

func (m *AgentConnectionFromCore) GetInstallBinary() *AgentConnectionFromCore_InstallBinary

func (*AgentConnectionFromCore) GetJobCancel 

func (m *AgentConnectionFromCore) GetJobCancel() *AgentConnectionFromCore_JobCancel

func (*AgentConnectionFromCore) GetJobNew 

func (m *AgentConnectionFromCore) GetJobNew() *AgentConnectionFromCore_JobNew

func (*AgentConnectionFromCore) GetJoinResponse 

func (m *AgentConnectionFromCore) GetJoinResponse() *AgentConnectionFromCore_JoinResponse

func (*AgentConnectionFromCore) GetMessageType 

func (m *AgentConnectionFromCore) GetMessageType() AgentConnectionFromCore_MessageType

func (*AgentConnectionFromCore) ProtoMessage 

func (*AgentConnectionFromCore) ProtoMessage()

func (*AgentConnectionFromCore) Reset 

func (m *AgentConnectionFromCore) Reset()

func (*AgentConnectionFromCore) String 

func (m *AgentConnectionFromCore) String() string

func (*AgentConnectionFromCore) XXX_DiscardUnknown 

func (m *AgentConnectionFromCore) XXX_DiscardUnknown()

func (*AgentConnectionFromCore) XXX_Marshal 

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

func (*AgentConnectionFromCore) XXX_Merge 

func (m *AgentConnectionFromCore) XXX_Merge(src proto.Message)

func (*AgentConnectionFromCore) XXX_Size 

func (m *AgentConnectionFromCore) XXX_Size() int

func (*AgentConnectionFromCore) XXX_Unmarshal 

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

type AgentConnectionFromCore_InstallBinary 

type AgentConnectionFromCore_InstallBinary struct {
	Bucket               string   `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Name                 string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AgentConnectionFromCore_InstallBinary) Descriptor 

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

func (*AgentConnectionFromCore_InstallBinary) GetBucket 

func (m *AgentConnectionFromCore_InstallBinary) GetBucket() string

func (*AgentConnectionFromCore_InstallBinary) GetName 

func (m *AgentConnectionFromCore_InstallBinary) GetName() string

func (*AgentConnectionFromCore_InstallBinary) ProtoMessage 

func (*AgentConnectionFromCore_InstallBinary) ProtoMessage()

func (*AgentConnectionFromCore_InstallBinary) Reset 

func (m *AgentConnectionFromCore_InstallBinary) Reset()

func (*AgentConnectionFromCore_InstallBinary) String 

func (m *AgentConnectionFromCore_InstallBinary) String() string

func (*AgentConnectionFromCore_InstallBinary) XXX_DiscardUnknown 

func (m *AgentConnectionFromCore_InstallBinary) XXX_DiscardUnknown()

func (*AgentConnectionFromCore_InstallBinary) XXX_Marshal 

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

func (*AgentConnectionFromCore_InstallBinary) XXX_Merge 

func (m *AgentConnectionFromCore_InstallBinary) XXX_Merge(src proto.Message)

func (*AgentConnectionFromCore_InstallBinary) XXX_Size 

func (m *AgentConnectionFromCore_InstallBinary) XXX_Size() int

func (*AgentConnectionFromCore_InstallBinary) XXX_Unmarshal 

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

type AgentConnectionFromCore_JobCancel 

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

func (*AgentConnectionFromCore_JobCancel) Descriptor 

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

func (*AgentConnectionFromCore_JobCancel) GetId 

func (m *AgentConnectionFromCore_JobCancel) GetId() uint32

func (*AgentConnectionFromCore_JobCancel) ProtoMessage 

func (*AgentConnectionFromCore_JobCancel) ProtoMessage()

func (*AgentConnectionFromCore_JobCancel) Reset 

func (m *AgentConnectionFromCore_JobCancel) Reset()

func (*AgentConnectionFromCore_JobCancel) String 

func (m *AgentConnectionFromCore_JobCancel) String() string

func (*AgentConnectionFromCore_JobCancel) XXX_DiscardUnknown 

func (m *AgentConnectionFromCore_JobCancel) XXX_DiscardUnknown()

func (*AgentConnectionFromCore_JobCancel) XXX_Marshal 

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

func (*AgentConnectionFromCore_JobCancel) XXX_Merge 

func (m *AgentConnectionFromCore_JobCancel) XXX_Merge(src proto.Message)

func (*AgentConnectionFromCore_JobCancel) XXX_Size 

func (m *AgentConnectionFromCore_JobCancel) XXX_Size() int

func (*AgentConnectionFromCore_JobCancel) XXX_Unmarshal 

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

type AgentConnectionFromCore_JobNew 

type AgentConnectionFromCore_JobNew struct {
	Id                   uint32   `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                 string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Config               string   `protobuf:"bytes,3,opt,name=config,proto3" json:"config,omitempty"`
	Target               string   `protobuf:"bytes,4,opt,name=target,proto3" json:"target,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AgentConnectionFromCore_JobNew) Descriptor 

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

func (*AgentConnectionFromCore_JobNew) GetConfig 

func (m *AgentConnectionFromCore_JobNew) GetConfig() string

func (*AgentConnectionFromCore_JobNew) GetId 

func (m *AgentConnectionFromCore_JobNew) GetId() uint32

func (*AgentConnectionFromCore_JobNew) GetName 

func (m *AgentConnectionFromCore_JobNew) GetName() string

func (*AgentConnectionFromCore_JobNew) GetTarget 

func (m *AgentConnectionFromCore_JobNew) GetTarget() string

func (*AgentConnectionFromCore_JobNew) ProtoMessage 

func (*AgentConnectionFromCore_JobNew) ProtoMessage()

func (*AgentConnectionFromCore_JobNew) Reset 

func (m *AgentConnectionFromCore_JobNew) Reset()

func (*AgentConnectionFromCore_JobNew) String 

func (m *AgentConnectionFromCore_JobNew) String() string

func (*AgentConnectionFromCore_JobNew) XXX_DiscardUnknown 

func (m *AgentConnectionFromCore_JobNew) XXX_DiscardUnknown()

func (*AgentConnectionFromCore_JobNew) XXX_Marshal 

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

func (*AgentConnectionFromCore_JobNew) XXX_Merge 

func (m *AgentConnectionFromCore_JobNew) XXX_Merge(src proto.Message)

func (*AgentConnectionFromCore_JobNew) XXX_Size 

func (m *AgentConnectionFromCore_JobNew) XXX_Size() int

func (*AgentConnectionFromCore_JobNew) XXX_Unmarshal 

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

type AgentConnectionFromCore_JoinResponse 

type AgentConnectionFromCore_JoinResponse struct {
	Status               AgentConnectionFromCore_JoinResponse_Status `protobuf:"varint,1,opt,name=status,proto3,enum=drlm.AgentConnectionFromCore_JoinResponse_Status" json:"status,omitempty"`
	CoreSecret           string                                      `protobuf:"bytes,2,opt,name=core_secret,json=coreSecret,proto3" json:"core_secret,omitempty"`
	MinioAccessKey       string                                      `protobuf:"bytes,3,opt,name=minio_access_key,json=minioAccessKey,proto3" json:"minio_access_key,omitempty"`
	MinioSecretKey       string                                      `protobuf:"bytes,4,opt,name=minio_secret_key,json=minioSecretKey,proto3" json:"minio_secret_key,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                                    `json:"-"`
	XXX_unrecognized     []byte                                      `json:"-"`
	XXX_sizecache        int32                                       `json:"-"`
}

func (*AgentConnectionFromCore_JoinResponse) Descriptor 

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

func (*AgentConnectionFromCore_JoinResponse) GetCoreSecret 

func (m *AgentConnectionFromCore_JoinResponse) GetCoreSecret() string

func (*AgentConnectionFromCore_JoinResponse) GetMinioAccessKey 

func (m *AgentConnectionFromCore_JoinResponse) GetMinioAccessKey() string

func (*AgentConnectionFromCore_JoinResponse) GetMinioSecretKey 

func (m *AgentConnectionFromCore_JoinResponse) GetMinioSecretKey() string

func (*AgentConnectionFromCore_JoinResponse) GetStatus 

func (m *AgentConnectionFromCore_JoinResponse) GetStatus() AgentConnectionFromCore_JoinResponse_Status

func (*AgentConnectionFromCore_JoinResponse) ProtoMessage 

func (*AgentConnectionFromCore_JoinResponse) ProtoMessage()

func (*AgentConnectionFromCore_JoinResponse) Reset 

func (m *AgentConnectionFromCore_JoinResponse) Reset()

func (*AgentConnectionFromCore_JoinResponse) String 

func (m *AgentConnectionFromCore_JoinResponse) String() string

func (*AgentConnectionFromCore_JoinResponse) XXX_DiscardUnknown 

func (m *AgentConnectionFromCore_JoinResponse) XXX_DiscardUnknown()

func (*AgentConnectionFromCore_JoinResponse) XXX_Marshal 

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

func (*AgentConnectionFromCore_JoinResponse) XXX_Merge 

func (m *AgentConnectionFromCore_JoinResponse) XXX_Merge(src proto.Message)

func (*AgentConnectionFromCore_JoinResponse) XXX_Size 

func (m *AgentConnectionFromCore_JoinResponse) XXX_Size() int

func (*AgentConnectionFromCore_JoinResponse) XXX_Unmarshal 

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

type AgentConnectionFromCore_JoinResponse_Status 

type AgentConnectionFromCore_JoinResponse_Status int32
const (
	AgentConnectionFromCore_JoinResponse_STATUS_UNKNOWN AgentConnectionFromCore_JoinResponse_Status = 0
	AgentConnectionFromCore_JoinResponse_STATUS_ACCEPT  AgentConnectionFromCore_JoinResponse_Status = 1
	AgentConnectionFromCore_JoinResponse_STATUS_REJECT  AgentConnectionFromCore_JoinResponse_Status = 2
)

func (AgentConnectionFromCore_JoinResponse_Status) EnumDescriptor 

func (AgentConnectionFromCore_JoinResponse_Status) EnumDescriptor() ([]byte, []int)

func (AgentConnectionFromCore_JoinResponse_Status) String 

func (x AgentConnectionFromCore_JoinResponse_Status) String() string

type AgentConnectionFromCore_MessageType 

type AgentConnectionFromCore_MessageType int32
const (
	AgentConnectionFromCore_MESSAGE_TYPE_UNKNOWN        AgentConnectionFromCore_MessageType = 0
	AgentConnectionFromCore_MESSAGE_TYPE_JOIN_RESPONSE  AgentConnectionFromCore_MessageType = 1
	AgentConnectionFromCore_MESSAGE_TYPE_JOB_NEW        AgentConnectionFromCore_MessageType = 2
	AgentConnectionFromCore_MESSAGE_TYPE_JOB_CANCEL     AgentConnectionFromCore_MessageType = 3
	AgentConnectionFromCore_MESSAGE_TYPE_INSTALL_BINARY AgentConnectionFromCore_MessageType = 4
)

func (AgentConnectionFromCore_MessageType) EnumDescriptor 

func (AgentConnectionFromCore_MessageType) EnumDescriptor() ([]byte, []int)

func (AgentConnectionFromCore_MessageType) String 

func (x AgentConnectionFromCore_MessageType) String() string

type AgentDeleteRequest 

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

func (*AgentDeleteRequest) Descriptor 

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

func (*AgentDeleteRequest) GetHost 

func (m *AgentDeleteRequest) GetHost() string

func (*AgentDeleteRequest) ProtoMessage 

func (*AgentDeleteRequest) ProtoMessage()

func (*AgentDeleteRequest) Reset 

func (m *AgentDeleteRequest) Reset()

func (*AgentDeleteRequest) String 

func (m *AgentDeleteRequest) String() string

func (*AgentDeleteRequest) XXX_DiscardUnknown 

func (m *AgentDeleteRequest) XXX_DiscardUnknown()

func (*AgentDeleteRequest) XXX_Marshal 

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

func (*AgentDeleteRequest) XXX_Merge 

func (m *AgentDeleteRequest) XXX_Merge(src proto.Message)

func (*AgentDeleteRequest) XXX_Size 

func (m *AgentDeleteRequest) XXX_Size() int

func (*AgentDeleteRequest) XXX_Unmarshal 

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

type AgentDeleteResponse 

type AgentDeleteResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AgentDeleteResponse) Descriptor 

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

func (*AgentDeleteResponse) ProtoMessage 

func (*AgentDeleteResponse) ProtoMessage()

func (*AgentDeleteResponse) Reset 

func (m *AgentDeleteResponse) Reset()

func (*AgentDeleteResponse) String 

func (m *AgentDeleteResponse) String() string

func (*AgentDeleteResponse) XXX_DiscardUnknown 

func (m *AgentDeleteResponse) XXX_DiscardUnknown()

func (*AgentDeleteResponse) XXX_Marshal 

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

func (*AgentDeleteResponse) XXX_Merge 

func (m *AgentDeleteResponse) XXX_Merge(src proto.Message)

func (*AgentDeleteResponse) XXX_Size 

func (m *AgentDeleteResponse) XXX_Size() int

func (*AgentDeleteResponse) XXX_Unmarshal 

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

type AgentGetRequest 

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

func (*AgentGetRequest) Descriptor 

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

func (*AgentGetRequest) GetHost 

func (m *AgentGetRequest) GetHost() string

func (*AgentGetRequest) ProtoMessage 

func (*AgentGetRequest) ProtoMessage()

func (*AgentGetRequest) Reset 

func (m *AgentGetRequest) Reset()

func (*AgentGetRequest) String 

func (m *AgentGetRequest) String() string

func (*AgentGetRequest) XXX_DiscardUnknown 

func (m *AgentGetRequest) XXX_DiscardUnknown()

func (*AgentGetRequest) XXX_Marshal 

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

func (*AgentGetRequest) XXX_Merge 

func (m *AgentGetRequest) XXX_Merge(src proto.Message)

func (*AgentGetRequest) XXX_Size 

func (m *AgentGetRequest) XXX_Size() int

func (*AgentGetRequest) XXX_Unmarshal 

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

type AgentGetResponse 

type AgentGetResponse struct {
	Host                 string               `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	Accepted             bool                 `protobuf:"varint,2,opt,name=accepted,proto3" json:"accepted,omitempty"`
	SshPort              int32                `protobuf:"varint,3,opt,name=ssh_port,json=sshPort,proto3" json:"ssh_port,omitempty"`
	SshUser              string               `protobuf:"bytes,4,opt,name=ssh_user,json=sshUser,proto3" json:"ssh_user,omitempty"`
	Version              string               `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"`
	Arch                 Arch                 `protobuf:"varint,6,opt,name=arch,proto3,enum=drlm.Arch" json:"arch,omitempty"`
	Os                   OS                   `protobuf:"varint,7,opt,name=os,proto3,enum=drlm.OS" json:"os,omitempty"`
	OsVersion            string               `protobuf:"bytes,8,opt,name=os_version,json=osVersion,proto3" json:"os_version,omitempty"`
	Distro               string               `protobuf:"bytes,9,opt,name=distro,proto3" json:"distro,omitempty"`
	DistroVersion        string               `protobuf:"bytes,10,opt,name=distro_version,json=distroVersion,proto3" json:"distro_version,omitempty"`
	CreatedAt            *timestamp.Timestamp `protobuf:"bytes,11,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt            *timestamp.Timestamp `protobuf:"bytes,12,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*AgentGetResponse) Descriptor 

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

func (*AgentGetResponse) GetAccepted 

func (m *AgentGetResponse) GetAccepted() bool

func (*AgentGetResponse) GetArch 

func (m *AgentGetResponse) GetArch() Arch

func (*AgentGetResponse) GetCreatedAt 

func (m *AgentGetResponse) GetCreatedAt() *timestamp.Timestamp

func (*AgentGetResponse) GetDistro 

func (m *AgentGetResponse) GetDistro() string

func (*AgentGetResponse) GetDistroVersion 

func (m *AgentGetResponse) GetDistroVersion() string

func (*AgentGetResponse) GetHost 

func (m *AgentGetResponse) GetHost() string

func (*AgentGetResponse) GetOs 

func (m *AgentGetResponse) GetOs() OS

func (*AgentGetResponse) GetOsVersion 

func (m *AgentGetResponse) GetOsVersion() string

func (*AgentGetResponse) GetSshPort 

func (m *AgentGetResponse) GetSshPort() int32

func (*AgentGetResponse) GetSshUser 

func (m *AgentGetResponse) GetSshUser() string

func (*AgentGetResponse) GetUpdatedAt 

func (m *AgentGetResponse) GetUpdatedAt() *timestamp.Timestamp

func (*AgentGetResponse) GetVersion 

func (m *AgentGetResponse) GetVersion() string

func (*AgentGetResponse) ProtoMessage 

func (*AgentGetResponse) ProtoMessage()

func (*AgentGetResponse) Reset 

func (m *AgentGetResponse) Reset()

func (*AgentGetResponse) String 

func (m *AgentGetResponse) String() string

func (*AgentGetResponse) XXX_DiscardUnknown 

func (m *AgentGetResponse) XXX_DiscardUnknown()

func (*AgentGetResponse) XXX_Marshal 

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

func (*AgentGetResponse) XXX_Merge 

func (m *AgentGetResponse) XXX_Merge(src proto.Message)

func (*AgentGetResponse) XXX_Size 

func (m *AgentGetResponse) XXX_Size() int

func (*AgentGetResponse) XXX_Unmarshal 

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

type AgentInstallRequest 

type AgentInstallRequest struct {
	Host                 string   `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	SshPort              int32    `protobuf:"varint,2,opt,name=ssh_port,json=sshPort,proto3" json:"ssh_port,omitempty"`
	SshUser              string   `protobuf:"bytes,3,opt,name=ssh_user,json=sshUser,proto3" json:"ssh_user,omitempty"`
	SshPassword          string   `protobuf:"bytes,4,opt,name=ssh_password,json=sshPassword,proto3" json:"ssh_password,omitempty"`
	Bin                  []byte   `protobuf:"bytes,5,opt,name=bin,proto3" json:"bin,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AgentInstallRequest) Descriptor 

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

func (*AgentInstallRequest) GetBin 

func (m *AgentInstallRequest) GetBin() []byte

func (*AgentInstallRequest) GetHost 

func (m *AgentInstallRequest) GetHost() string

func (*AgentInstallRequest) GetSshPassword 

func (m *AgentInstallRequest) GetSshPassword() string

func (*AgentInstallRequest) GetSshPort 

func (m *AgentInstallRequest) GetSshPort() int32

func (*AgentInstallRequest) GetSshUser 

func (m *AgentInstallRequest) GetSshUser() string

func (*AgentInstallRequest) ProtoMessage 

func (*AgentInstallRequest) ProtoMessage()

func (*AgentInstallRequest) Reset 

func (m *AgentInstallRequest) Reset()

func (*AgentInstallRequest) String 

func (m *AgentInstallRequest) String() string

func (*AgentInstallRequest) XXX_DiscardUnknown 

func (m *AgentInstallRequest) XXX_DiscardUnknown()

func (*AgentInstallRequest) XXX_Marshal 

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

func (*AgentInstallRequest) XXX_Merge 

func (m *AgentInstallRequest) XXX_Merge(src proto.Message)

func (*AgentInstallRequest) XXX_Size 

func (m *AgentInstallRequest) XXX_Size() int

func (*AgentInstallRequest) XXX_Unmarshal 

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

type AgentInstallResponse 

type AgentInstallResponse struct {
	Message              string                    `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	Code                 AgentInstallResponse_Code `protobuf:"varint,2,opt,name=code,proto3,enum=drlm.AgentInstallResponse_Code" json:"code,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*AgentInstallResponse) Descriptor 

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

func (*AgentInstallResponse) GetCode 

func (m *AgentInstallResponse) GetCode() AgentInstallResponse_Code

func (*AgentInstallResponse) GetMessage 

func (m *AgentInstallResponse) GetMessage() string

func (*AgentInstallResponse) ProtoMessage 

func (*AgentInstallResponse) ProtoMessage()

func (*AgentInstallResponse) Reset 

func (m *AgentInstallResponse) Reset()

func (*AgentInstallResponse) String 

func (m *AgentInstallResponse) String() string

func (*AgentInstallResponse) XXX_DiscardUnknown 

func (m *AgentInstallResponse) XXX_DiscardUnknown()

func (*AgentInstallResponse) XXX_Marshal 

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

func (*AgentInstallResponse) XXX_Merge 

func (m *AgentInstallResponse) XXX_Merge(src proto.Message)

func (*AgentInstallResponse) XXX_Size 

func (m *AgentInstallResponse) XXX_Size() int

func (*AgentInstallResponse) XXX_Unmarshal 

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

type AgentInstallResponse_Code 

type AgentInstallResponse_Code int32
const (
	AgentInstallResponse_UNKNOWN AgentInstallResponse_Code = 0
	AgentInstallResponse_OK      AgentInstallResponse_Code = 1
	AgentInstallResponse_FAILED  AgentInstallResponse_Code = 2
)

func (AgentInstallResponse_Code) EnumDescriptor 

func (AgentInstallResponse_Code) EnumDescriptor() ([]byte, []int)

func (AgentInstallResponse_Code) String 

func (x AgentInstallResponse_Code) String() string

type AgentListRequest 

type AgentListRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AgentListRequest) Descriptor 

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

func (*AgentListRequest) ProtoMessage 

func (*AgentListRequest) ProtoMessage()

func (*AgentListRequest) Reset 

func (m *AgentListRequest) Reset()

func (*AgentListRequest) String 

func (m *AgentListRequest) String() string

func (*AgentListRequest) XXX_DiscardUnknown 

func (m *AgentListRequest) XXX_DiscardUnknown()

func (*AgentListRequest) XXX_Marshal 

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

func (*AgentListRequest) XXX_Merge 

func (m *AgentListRequest) XXX_Merge(src proto.Message)

func (*AgentListRequest) XXX_Size 

func (m *AgentListRequest) XXX_Size() int

func (*AgentListRequest) XXX_Unmarshal 

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

type AgentListResponse 

type AgentListResponse struct {
	Agents               []*AgentListResponse_Agent `protobuf:"bytes,1,rep,name=agents,proto3" json:"agents,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

func (*AgentListResponse) Descriptor 

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

func (*AgentListResponse) GetAgents 

func (m *AgentListResponse) GetAgents() []*AgentListResponse_Agent

func (*AgentListResponse) ProtoMessage 

func (*AgentListResponse) ProtoMessage()

func (*AgentListResponse) Reset 

func (m *AgentListResponse) Reset()

func (*AgentListResponse) String 

func (m *AgentListResponse) String() string

func (*AgentListResponse) XXX_DiscardUnknown 

func (m *AgentListResponse) XXX_DiscardUnknown()

func (*AgentListResponse) XXX_Marshal 

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

func (*AgentListResponse) XXX_Merge 

func (m *AgentListResponse) XXX_Merge(src proto.Message)

func (*AgentListResponse) XXX_Size 

func (m *AgentListResponse) XXX_Size() int

func (*AgentListResponse) XXX_Unmarshal 

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

type AgentListResponse_Agent 

type AgentListResponse_Agent struct {
	Host                 string               `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	SshPort              int32                `protobuf:"varint,2,opt,name=ssh_port,json=sshPort,proto3" json:"ssh_port,omitempty"`
	SshUser              string               `protobuf:"bytes,3,opt,name=ssh_user,json=sshUser,proto3" json:"ssh_user,omitempty"`
	Version              string               `protobuf:"bytes,4,opt,name=version,proto3" json:"version,omitempty"`
	Arch                 Arch                 `protobuf:"varint,5,opt,name=arch,proto3,enum=drlm.Arch" json:"arch,omitempty"`
	Os                   OS                   `protobuf:"varint,6,opt,name=os,proto3,enum=drlm.OS" json:"os,omitempty"`
	OsVersion            string               `protobuf:"bytes,7,opt,name=os_version,json=osVersion,proto3" json:"os_version,omitempty"`
	Distro               string               `protobuf:"bytes,8,opt,name=distro,proto3" json:"distro,omitempty"`
	DistroVersion        string               `protobuf:"bytes,9,opt,name=distro_version,json=distroVersion,proto3" json:"distro_version,omitempty"`
	CreatedAt            *timestamp.Timestamp `protobuf:"bytes,10,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt            *timestamp.Timestamp `protobuf:"bytes,11,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*AgentListResponse_Agent) Descriptor 

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

func (*AgentListResponse_Agent) GetArch 

func (m *AgentListResponse_Agent) GetArch() Arch

func (*AgentListResponse_Agent) GetCreatedAt 

func (m *AgentListResponse_Agent) GetCreatedAt() *timestamp.Timestamp

func (*AgentListResponse_Agent) GetDistro 

func (m *AgentListResponse_Agent) GetDistro() string

func (*AgentListResponse_Agent) GetDistroVersion 

func (m *AgentListResponse_Agent) GetDistroVersion() string

func (*AgentListResponse_Agent) GetHost 

func (m *AgentListResponse_Agent) GetHost() string

func (*AgentListResponse_Agent) GetOs 

func (m *AgentListResponse_Agent) GetOs() OS

func (*AgentListResponse_Agent) GetOsVersion 

func (m *AgentListResponse_Agent) GetOsVersion() string

func (*AgentListResponse_Agent) GetSshPort 

func (m *AgentListResponse_Agent) GetSshPort() int32

func (*AgentListResponse_Agent) GetSshUser 

func (m *AgentListResponse_Agent) GetSshUser() string

func (*AgentListResponse_Agent) GetUpdatedAt 

func (m *AgentListResponse_Agent) GetUpdatedAt() *timestamp.Timestamp

func (*AgentListResponse_Agent) GetVersion 

func (m *AgentListResponse_Agent) GetVersion() string

func (*AgentListResponse_Agent) ProtoMessage 

func (*AgentListResponse_Agent) ProtoMessage()

func (*AgentListResponse_Agent) Reset 

func (m *AgentListResponse_Agent) Reset()

func (*AgentListResponse_Agent) String 

func (m *AgentListResponse_Agent) String() string

func (*AgentListResponse_Agent) XXX_DiscardUnknown 

func (m *AgentListResponse_Agent) XXX_DiscardUnknown()

func (*AgentListResponse_Agent) XXX_Marshal 

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

func (*AgentListResponse_Agent) XXX_Merge 

func (m *AgentListResponse_Agent) XXX_Merge(src proto.Message)

func (*AgentListResponse_Agent) XXX_Size 

func (m *AgentListResponse_Agent) XXX_Size() int

func (*AgentListResponse_Agent) XXX_Unmarshal 

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

type AgentPluginAddRequest 

type AgentPluginAddRequest struct {
	Host                 string   `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	Repo                 string   `protobuf:"bytes,2,opt,name=repo,proto3" json:"repo,omitempty"`
	Plugin               string   `protobuf:"bytes,3,opt,name=plugin,proto3" json:"plugin,omitempty"`
	Version              string   `protobuf:"bytes,4,opt,name=version,proto3" json:"version,omitempty"`
	Arch                 []Arch   `protobuf:"varint,6,rep,packed,name=arch,proto3,enum=drlm.Arch" json:"arch,omitempty"`
	Os                   []OS     `protobuf:"varint,5,rep,packed,name=os,proto3,enum=drlm.OS" json:"os,omitempty"`
	Bin                  []byte   `protobuf:"bytes,7,opt,name=bin,proto3" json:"bin,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AgentPluginAddRequest) Descriptor 

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

func (*AgentPluginAddRequest) GetArch 

func (m *AgentPluginAddRequest) GetArch() []Arch

func (*AgentPluginAddRequest) GetBin 

func (m *AgentPluginAddRequest) GetBin() []byte

func (*AgentPluginAddRequest) GetHost 

func (m *AgentPluginAddRequest) GetHost() string

func (*AgentPluginAddRequest) GetOs 

func (m *AgentPluginAddRequest) GetOs() []OS

func (*AgentPluginAddRequest) GetPlugin 

func (m *AgentPluginAddRequest) GetPlugin() string

func (*AgentPluginAddRequest) GetRepo 

func (m *AgentPluginAddRequest) GetRepo() string

func (*AgentPluginAddRequest) GetVersion 

func (m *AgentPluginAddRequest) GetVersion() string

func (*AgentPluginAddRequest) ProtoMessage 

func (*AgentPluginAddRequest) ProtoMessage()

func (*AgentPluginAddRequest) Reset 

func (m *AgentPluginAddRequest) Reset()

func (*AgentPluginAddRequest) String 

func (m *AgentPluginAddRequest) String() string

func (*AgentPluginAddRequest) XXX_DiscardUnknown 

func (m *AgentPluginAddRequest) XXX_DiscardUnknown()

func (*AgentPluginAddRequest) XXX_Marshal 

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

func (*AgentPluginAddRequest) XXX_Merge 

func (m *AgentPluginAddRequest) XXX_Merge(src proto.Message)

func (*AgentPluginAddRequest) XXX_Size 

func (m *AgentPluginAddRequest) XXX_Size() int

func (*AgentPluginAddRequest) XXX_Unmarshal 

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

type AgentPluginAddResponse 

type AgentPluginAddResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AgentPluginAddResponse) Descriptor 

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

func (*AgentPluginAddResponse) ProtoMessage 

func (*AgentPluginAddResponse) ProtoMessage()

func (*AgentPluginAddResponse) Reset 

func (m *AgentPluginAddResponse) Reset()

func (*AgentPluginAddResponse) String 

func (m *AgentPluginAddResponse) String() string

func (*AgentPluginAddResponse) XXX_DiscardUnknown 

func (m *AgentPluginAddResponse) XXX_DiscardUnknown()

func (*AgentPluginAddResponse) XXX_Marshal 

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

func (*AgentPluginAddResponse) XXX_Merge 

func (m *AgentPluginAddResponse) XXX_Merge(src proto.Message)

func (*AgentPluginAddResponse) XXX_Size 

func (m *AgentPluginAddResponse) XXX_Size() int

func (*AgentPluginAddResponse) XXX_Unmarshal 

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

type AgentPluginListRequest 

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

func (*AgentPluginListRequest) Descriptor 

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

func (*AgentPluginListRequest) GetHost 

func (m *AgentPluginListRequest) GetHost() string

func (*AgentPluginListRequest) ProtoMessage 

func (*AgentPluginListRequest) ProtoMessage()

func (*AgentPluginListRequest) Reset 

func (m *AgentPluginListRequest) Reset()

func (*AgentPluginListRequest) String 

func (m *AgentPluginListRequest) String() string

func (*AgentPluginListRequest) XXX_DiscardUnknown 

func (m *AgentPluginListRequest) XXX_DiscardUnknown()

func (*AgentPluginListRequest) XXX_Marshal 

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

func (*AgentPluginListRequest) XXX_Merge 

func (m *AgentPluginListRequest) XXX_Merge(src proto.Message)

func (*AgentPluginListRequest) XXX_Size 

func (m *AgentPluginListRequest) XXX_Size() int

func (*AgentPluginListRequest) XXX_Unmarshal 

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

type AgentPluginListResponse 

type AgentPluginListResponse struct {
	Plugins              []string `protobuf:"bytes,1,rep,name=plugins,proto3" json:"plugins,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AgentPluginListResponse) Descriptor 

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

func (*AgentPluginListResponse) GetPlugins 

func (m *AgentPluginListResponse) GetPlugins() []string

func (*AgentPluginListResponse) ProtoMessage 

func (*AgentPluginListResponse) ProtoMessage()

func (*AgentPluginListResponse) Reset 

func (m *AgentPluginListResponse) Reset()

func (*AgentPluginListResponse) String 

func (m *AgentPluginListResponse) String() string

func (*AgentPluginListResponse) XXX_DiscardUnknown 

func (m *AgentPluginListResponse) XXX_DiscardUnknown()

func (*AgentPluginListResponse) XXX_Marshal 

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

func (*AgentPluginListResponse) XXX_Merge 

func (m *AgentPluginListResponse) XXX_Merge(src proto.Message)

func (*AgentPluginListResponse) XXX_Size 

func (m *AgentPluginListResponse) XXX_Size() int

func (*AgentPluginListResponse) XXX_Unmarshal 

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

type AgentPluginRemoveRequest 

type AgentPluginRemoveRequest struct {
	Host                 string   `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	Plugin               string   `protobuf:"bytes,2,opt,name=plugin,proto3" json:"plugin,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AgentPluginRemoveRequest) Descriptor 

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

func (*AgentPluginRemoveRequest) GetHost 

func (m *AgentPluginRemoveRequest) GetHost() string

func (*AgentPluginRemoveRequest) GetPlugin 

func (m *AgentPluginRemoveRequest) GetPlugin() string

func (*AgentPluginRemoveRequest) ProtoMessage 

func (*AgentPluginRemoveRequest) ProtoMessage()

func (*AgentPluginRemoveRequest) Reset 

func (m *AgentPluginRemoveRequest) Reset()

func (*AgentPluginRemoveRequest) String 

func (m *AgentPluginRemoveRequest) String() string

func (*AgentPluginRemoveRequest) XXX_DiscardUnknown 

func (m *AgentPluginRemoveRequest) XXX_DiscardUnknown()

func (*AgentPluginRemoveRequest) XXX_Marshal 

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

func (*AgentPluginRemoveRequest) XXX_Merge 

func (m *AgentPluginRemoveRequest) XXX_Merge(src proto.Message)

func (*AgentPluginRemoveRequest) XXX_Size 

func (m *AgentPluginRemoveRequest) XXX_Size() int

func (*AgentPluginRemoveRequest) XXX_Unmarshal 

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

type AgentPluginRemoveResponse 

type AgentPluginRemoveResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AgentPluginRemoveResponse) Descriptor 

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

func (*AgentPluginRemoveResponse) ProtoMessage 

func (*AgentPluginRemoveResponse) ProtoMessage()

func (*AgentPluginRemoveResponse) Reset 

func (m *AgentPluginRemoveResponse) Reset()

func (*AgentPluginRemoveResponse) String 

func (m *AgentPluginRemoveResponse) String() string

func (*AgentPluginRemoveResponse) XXX_DiscardUnknown 

func (m *AgentPluginRemoveResponse) XXX_DiscardUnknown()

func (*AgentPluginRemoveResponse) XXX_Marshal 

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

func (*AgentPluginRemoveResponse) XXX_Merge 

func (m *AgentPluginRemoveResponse) XXX_Merge(src proto.Message)

func (*AgentPluginRemoveResponse) XXX_Size 

func (m *AgentPluginRemoveResponse) XXX_Size() int

func (*AgentPluginRemoveResponse) XXX_Unmarshal 

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

type AgentPluginUpdateRequest 

type AgentPluginUpdateRequest struct {
	Host                 string   `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	Plugin               string   `protobuf:"bytes,2,opt,name=plugin,proto3" json:"plugin,omitempty"`
	Version              string   `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	Bin                  []byte   `protobuf:"bytes,5,opt,name=bin,proto3" json:"bin,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AgentPluginUpdateRequest) Descriptor 

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

func (*AgentPluginUpdateRequest) GetBin 

func (m *AgentPluginUpdateRequest) GetBin() []byte

func (*AgentPluginUpdateRequest) GetHost 

func (m *AgentPluginUpdateRequest) GetHost() string

func (*AgentPluginUpdateRequest) GetPlugin 

func (m *AgentPluginUpdateRequest) GetPlugin() string

func (*AgentPluginUpdateRequest) GetVersion 

func (m *AgentPluginUpdateRequest) GetVersion() string

func (*AgentPluginUpdateRequest) ProtoMessage 

func (*AgentPluginUpdateRequest) ProtoMessage()

func (*AgentPluginUpdateRequest) Reset 

func (m *AgentPluginUpdateRequest) Reset()

func (*AgentPluginUpdateRequest) String 

func (m *AgentPluginUpdateRequest) String() string

func (*AgentPluginUpdateRequest) XXX_DiscardUnknown 

func (m *AgentPluginUpdateRequest) XXX_DiscardUnknown()

func (*AgentPluginUpdateRequest) XXX_Marshal 

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

func (*AgentPluginUpdateRequest) XXX_Merge 

func (m *AgentPluginUpdateRequest) XXX_Merge(src proto.Message)

func (*AgentPluginUpdateRequest) XXX_Size 

func (m *AgentPluginUpdateRequest) XXX_Size() int

func (*AgentPluginUpdateRequest) XXX_Unmarshal 

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

type AgentPluginUpdateResponse 

type AgentPluginUpdateResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AgentPluginUpdateResponse) Descriptor 

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

func (*AgentPluginUpdateResponse) ProtoMessage 

func (*AgentPluginUpdateResponse) ProtoMessage()

func (*AgentPluginUpdateResponse) Reset 

func (m *AgentPluginUpdateResponse) Reset()

func (*AgentPluginUpdateResponse) String 

func (m *AgentPluginUpdateResponse) String() string

func (*AgentPluginUpdateResponse) XXX_DiscardUnknown 

func (m *AgentPluginUpdateResponse) XXX_DiscardUnknown()

func (*AgentPluginUpdateResponse) XXX_Marshal 

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

func (*AgentPluginUpdateResponse) XXX_Merge 

func (m *AgentPluginUpdateResponse) XXX_Merge(src proto.Message)

func (*AgentPluginUpdateResponse) XXX_Size 

func (m *AgentPluginUpdateResponse) XXX_Size() int

func (*AgentPluginUpdateResponse) XXX_Unmarshal 

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

type AgentRequestListRequest 

type AgentRequestListRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AgentRequestListRequest) Descriptor 

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

func (*AgentRequestListRequest) ProtoMessage 

func (*AgentRequestListRequest) ProtoMessage()

func (*AgentRequestListRequest) Reset 

func (m *AgentRequestListRequest) Reset()

func (*AgentRequestListRequest) String 

func (m *AgentRequestListRequest) String() string

func (*AgentRequestListRequest) XXX_DiscardUnknown 

func (m *AgentRequestListRequest) XXX_DiscardUnknown()

func (*AgentRequestListRequest) XXX_Marshal 

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

func (*AgentRequestListRequest) XXX_Merge 

func (m *AgentRequestListRequest) XXX_Merge(src proto.Message)

func (*AgentRequestListRequest) XXX_Size 

func (m *AgentRequestListRequest) XXX_Size() int

func (*AgentRequestListRequest) XXX_Unmarshal 

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

type AgentRequestListResponse 

type AgentRequestListResponse struct {
	Agents               []*AgentRequestListResponse_Agent `protobuf:"bytes,1,rep,name=agents,proto3" json:"agents,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                          `json:"-"`
	XXX_unrecognized     []byte                            `json:"-"`
	XXX_sizecache        int32                             `json:"-"`
}

func (*AgentRequestListResponse) Descriptor 

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

func (*AgentRequestListResponse) GetAgents 

func (m *AgentRequestListResponse) GetAgents() []*AgentRequestListResponse_Agent

func (*AgentRequestListResponse) ProtoMessage 

func (*AgentRequestListResponse) ProtoMessage()

func (*AgentRequestListResponse) Reset 

func (m *AgentRequestListResponse) Reset()

func (*AgentRequestListResponse) String 

func (m *AgentRequestListResponse) String() string

func (*AgentRequestListResponse) XXX_DiscardUnknown 

func (m *AgentRequestListResponse) XXX_DiscardUnknown()

func (*AgentRequestListResponse) XXX_Marshal 

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

func (*AgentRequestListResponse) XXX_Merge 

func (m *AgentRequestListResponse) XXX_Merge(src proto.Message)

func (*AgentRequestListResponse) XXX_Size 

func (m *AgentRequestListResponse) XXX_Size() int

func (*AgentRequestListResponse) XXX_Unmarshal 

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

type AgentRequestListResponse_Agent 

type AgentRequestListResponse_Agent struct {
	Host                 string               `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	Version              string               `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Arch                 Arch                 `protobuf:"varint,3,opt,name=arch,proto3,enum=drlm.Arch" json:"arch,omitempty"`
	Os                   OS                   `protobuf:"varint,4,opt,name=os,proto3,enum=drlm.OS" json:"os,omitempty"`
	OsVersion            string               `protobuf:"bytes,5,opt,name=os_version,json=osVersion,proto3" json:"os_version,omitempty"`
	Distro               string               `protobuf:"bytes,6,opt,name=distro,proto3" json:"distro,omitempty"`
	DistroVersion        string               `protobuf:"bytes,7,opt,name=distro_version,json=distroVersion,proto3" json:"distro_version,omitempty"`
	CreatedAt            *timestamp.Timestamp `protobuf:"bytes,8,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt            *timestamp.Timestamp `protobuf:"bytes,9,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*AgentRequestListResponse_Agent) Descriptor 

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

func (*AgentRequestListResponse_Agent) GetArch 

func (m *AgentRequestListResponse_Agent) GetArch() Arch

func (*AgentRequestListResponse_Agent) GetCreatedAt 

func (m *AgentRequestListResponse_Agent) GetCreatedAt() *timestamp.Timestamp

func (*AgentRequestListResponse_Agent) GetDistro 

func (m *AgentRequestListResponse_Agent) GetDistro() string

func (*AgentRequestListResponse_Agent) GetDistroVersion 

func (m *AgentRequestListResponse_Agent) GetDistroVersion() string

func (*AgentRequestListResponse_Agent) GetHost 

func (m *AgentRequestListResponse_Agent) GetHost() string

func (*AgentRequestListResponse_Agent) GetOs 

func (m *AgentRequestListResponse_Agent) GetOs() OS

func (*AgentRequestListResponse_Agent) GetOsVersion 

func (m *AgentRequestListResponse_Agent) GetOsVersion() string

func (*AgentRequestListResponse_Agent) GetUpdatedAt 

func (m *AgentRequestListResponse_Agent) GetUpdatedAt() *timestamp.Timestamp

func (*AgentRequestListResponse_Agent) GetVersion 

func (m *AgentRequestListResponse_Agent) GetVersion() string

func (*AgentRequestListResponse_Agent) ProtoMessage 

func (*AgentRequestListResponse_Agent) ProtoMessage()

func (*AgentRequestListResponse_Agent) Reset 

func (m *AgentRequestListResponse_Agent) Reset()

func (*AgentRequestListResponse_Agent) String 

func (m *AgentRequestListResponse_Agent) String() string

func (*AgentRequestListResponse_Agent) XXX_DiscardUnknown 

func (m *AgentRequestListResponse_Agent) XXX_DiscardUnknown()

func (*AgentRequestListResponse_Agent) XXX_Marshal 

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

func (*AgentRequestListResponse_Agent) XXX_Merge 

func (m *AgentRequestListResponse_Agent) XXX_Merge(src proto.Message)

func (*AgentRequestListResponse_Agent) XXX_Size 

func (m *AgentRequestListResponse_Agent) XXX_Size() int

func (*AgentRequestListResponse_Agent) XXX_Unmarshal 

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

type Arch 

type Arch int32
const (
	Arch_ARCH_UNKNOWN Arch = 0
	Arch_ARCH_AMD64   Arch = 1
)

func (Arch) EnumDescriptor 

func (Arch) EnumDescriptor() ([]byte, []int)

func (Arch) String 

func (x Arch) String() string

type AuthType 

type AuthType int32
const (
	AuthType_AUTH_UNKNOWN AuthType = 0
	AuthType_AUTH_LOCAL   AuthType = 1
)

func (AuthType) EnumDescriptor 

func (AuthType) EnumDescriptor() ([]byte, []int)

func (AuthType) String 

func (x AuthType) String() string

type DRLMClient 

type DRLMClient interface {
	// UserLogin logs in as a local user
	UserLogin(ctx context.Context, in *UserLoginRequest, opts ...grpc.CallOption) (*UserLoginResponse, error)
	// UserTokenRenew renews the login token
	UserTokenRenew(ctx context.Context, in *UserTokenRenewRequest, opts ...grpc.CallOption) (*UserTokenRenewResponse, error)
	// UserAdd creates a new user
	UserAdd(ctx context.Context, in *UserAddRequest, opts ...grpc.CallOption) (*UserAddResponse, error)
	// UserDelete removes an user
	UserDelete(ctx context.Context, in *UserDeleteRequest, opts ...grpc.CallOption) (*UserDeleteResponse, error)
	// UserList lists all the users
	UserList(ctx context.Context, in *UserListRequest, opts ...grpc.CallOption) (*UserListResponse, error)
	// AgentAdd adds a new Agent to the DB
	AgentAdd(ctx context.Context, in *AgentAddRequest, opts ...grpc.CallOption) (*AgentAddResponse, error)
	// AgentAccept accepts a request to join DRLM that has made an Agent
	AgentAccept(ctx context.Context, in *AgentAcceptRequest, opts ...grpc.CallOption) (*AgentAcceptResponse, error)
	// AgentInstall installs the agent binary to the agent machine
	AgentInstall(ctx context.Context, opts ...grpc.CallOption) (DRLM_AgentInstallClient, error)
	// AgentDelete removes the agent from the DB and might do a clenup in the agent machine
	AgentDelete(ctx context.Context, in *AgentDeleteRequest, opts ...grpc.CallOption) (*AgentDeleteResponse, error)
	// AgentList returns a list of all the agents
	AgentList(ctx context.Context, in *AgentListRequest, opts ...grpc.CallOption) (*AgentListResponse, error)
	// AgentRequestList returns a list of all the agents that have requested to join DRLM
	AgentRequestList(ctx context.Context, in *AgentRequestListRequest, opts ...grpc.CallOption) (*AgentRequestListResponse, error)
	// AgentGet returns a specific agent
	AgentGet(ctx context.Context, in *AgentGetRequest, opts ...grpc.CallOption) (*AgentGetResponse, error)
	// AgentPluginAdd adds a new plugin to the Agent
	AgentPluginAdd(ctx context.Context, opts ...grpc.CallOption) (DRLM_AgentPluginAddClient, error)
	// AgentPluginRemove removes a plugin from the Agent
	AgentPluginRemove(ctx context.Context, in *AgentPluginRemoveRequest, opts ...grpc.CallOption) (*AgentPluginRemoveResponse, error)
	// AgentPluginUpdate updates a plugin of the Agent
	AgentPluginUpdate(ctx context.Context, opts ...grpc.CallOption) (DRLM_AgentPluginUpdateClient, error)
	// AgentPluginList lists the plugins of the Agent
	AgentPluginList(ctx context.Context, in *AgentPluginListRequest, opts ...grpc.CallOption) (*AgentPluginListResponse, error)
	// AgentConnection creates the connection between the Agent and the Core. It's used for both notifying new jobs and for returning the response / updates of them
	AgentConnection(ctx context.Context, opts ...grpc.CallOption) (DRLM_AgentConnectionClient, error)
	// JobSchedule schedules a new job
	JobSchedule(ctx context.Context, in *JobScheduleRequest, opts ...grpc.CallOption) (*JobScheduleResponse, error)
	// JobCancel cancels an scheduled or running Job
	JobCancel(ctx context.Context, in *JobCancelRequest, opts ...grpc.CallOption) (*JobCancelResponse, error)
	// JobList returns a list with the the jobs of an agent. If the agent ID is 0, it will return all the jobs
	JobList(ctx context.Context, in *JobListRequest, opts ...grpc.CallOption) (*JobListResponse, error)
}

DRLMClient is the client API for DRLM service.

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

func NewDRLMClient 

func NewDRLMClient(cc grpc.ClientConnInterface) DRLMClient

type DRLMServer 

type DRLMServer interface {
	// UserLogin logs in as a local user
	UserLogin(context.Context, *UserLoginRequest) (*UserLoginResponse, error)
	// UserTokenRenew renews the login token
	UserTokenRenew(context.Context, *UserTokenRenewRequest) (*UserTokenRenewResponse, error)
	// UserAdd creates a new user
	UserAdd(context.Context, *UserAddRequest) (*UserAddResponse, error)
	// UserDelete removes an user
	UserDelete(context.Context, *UserDeleteRequest) (*UserDeleteResponse, error)
	// UserList lists all the users
	UserList(context.Context, *UserListRequest) (*UserListResponse, error)
	// AgentAdd adds a new Agent to the DB
	AgentAdd(context.Context, *AgentAddRequest) (*AgentAddResponse, error)
	// AgentAccept accepts a request to join DRLM that has made an Agent
	AgentAccept(context.Context, *AgentAcceptRequest) (*AgentAcceptResponse, error)
	// AgentInstall installs the agent binary to the agent machine
	AgentInstall(DRLM_AgentInstallServer) error
	// AgentDelete removes the agent from the DB and might do a clenup in the agent machine
	AgentDelete(context.Context, *AgentDeleteRequest) (*AgentDeleteResponse, error)
	// AgentList returns a list of all the agents
	AgentList(context.Context, *AgentListRequest) (*AgentListResponse, error)
	// AgentRequestList returns a list of all the agents that have requested to join DRLM
	AgentRequestList(context.Context, *AgentRequestListRequest) (*AgentRequestListResponse, error)
	// AgentGet returns a specific agent
	AgentGet(context.Context, *AgentGetRequest) (*AgentGetResponse, error)
	// AgentPluginAdd adds a new plugin to the Agent
	AgentPluginAdd(DRLM_AgentPluginAddServer) error
	// AgentPluginRemove removes a plugin from the Agent
	AgentPluginRemove(context.Context, *AgentPluginRemoveRequest) (*AgentPluginRemoveResponse, error)
	// AgentPluginUpdate updates a plugin of the Agent
	AgentPluginUpdate(DRLM_AgentPluginUpdateServer) error
	// AgentPluginList lists the plugins of the Agent
	AgentPluginList(context.Context, *AgentPluginListRequest) (*AgentPluginListResponse, error)
	// AgentConnection creates the connection between the Agent and the Core. It's used for both notifying new jobs and for returning the response / updates of them
	AgentConnection(DRLM_AgentConnectionServer) error
	// JobSchedule schedules a new job
	JobSchedule(context.Context, *JobScheduleRequest) (*JobScheduleResponse, error)
	// JobCancel cancels an scheduled or running Job
	JobCancel(context.Context, *JobCancelRequest) (*JobCancelResponse, error)
	// JobList returns a list with the the jobs of an agent. If the agent ID is 0, it will return all the jobs
	JobList(context.Context, *JobListRequest) (*JobListResponse, error)
}

DRLMServer is the server API for DRLM service.

type DRLM_AgentConnectionClient 

type DRLM_AgentConnectionClient interface {
	Send(*AgentConnectionFromAgent) error
	Recv() (*AgentConnectionFromCore, error)
	grpc.ClientStream
}

type DRLM_AgentConnectionServer 

type DRLM_AgentConnectionServer interface {
	Send(*AgentConnectionFromCore) error
	Recv() (*AgentConnectionFromAgent, error)
	grpc.ServerStream
}

type DRLM_AgentInstallClient 

type DRLM_AgentInstallClient interface {
	Send(*AgentInstallRequest) error
	CloseAndRecv() (*AgentInstallResponse, error)
	grpc.ClientStream
}

type DRLM_AgentInstallServer 

type DRLM_AgentInstallServer interface {
	SendAndClose(*AgentInstallResponse) error
	Recv() (*AgentInstallRequest, error)
	grpc.ServerStream
}

type DRLM_AgentPluginAddClient 

type DRLM_AgentPluginAddClient interface {
	Send(*AgentPluginAddRequest) error
	CloseAndRecv() (*AgentPluginAddResponse, error)
	grpc.ClientStream
}

type DRLM_AgentPluginAddServer 

type DRLM_AgentPluginAddServer interface {
	SendAndClose(*AgentPluginAddResponse) error
	Recv() (*AgentPluginAddRequest, error)
	grpc.ServerStream
}

type DRLM_AgentPluginUpdateClient 

type DRLM_AgentPluginUpdateClient interface {
	Send(*AgentPluginUpdateRequest) error
	CloseAndRecv() (*AgentPluginUpdateResponse, error)
	grpc.ClientStream
}

type DRLM_AgentPluginUpdateServer 

type DRLM_AgentPluginUpdateServer interface {
	SendAndClose(*AgentPluginUpdateResponse) error
	Recv() (*AgentPluginUpdateRequest, error)
	grpc.ServerStream
}

type JobCancelRequest 

type JobCancelRequest struct {
	JobId                uint32   `protobuf:"varint,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*JobCancelRequest) Descriptor 

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

func (*JobCancelRequest) GetJobId 

func (m *JobCancelRequest) GetJobId() uint32

func (*JobCancelRequest) ProtoMessage 

func (*JobCancelRequest) ProtoMessage()

func (*JobCancelRequest) Reset 

func (m *JobCancelRequest) Reset()

func (*JobCancelRequest) String 

func (m *JobCancelRequest) String() string

func (*JobCancelRequest) XXX_DiscardUnknown 

func (m *JobCancelRequest) XXX_DiscardUnknown()

func (*JobCancelRequest) XXX_Marshal 

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

func (*JobCancelRequest) XXX_Merge 

func (m *JobCancelRequest) XXX_Merge(src proto.Message)

func (*JobCancelRequest) XXX_Size 

func (m *JobCancelRequest) XXX_Size() int

func (*JobCancelRequest) XXX_Unmarshal 

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

type JobCancelResponse 

type JobCancelResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*JobCancelResponse) Descriptor 

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

func (*JobCancelResponse) ProtoMessage 

func (*JobCancelResponse) ProtoMessage()

func (*JobCancelResponse) Reset 

func (m *JobCancelResponse) Reset()

func (*JobCancelResponse) String 

func (m *JobCancelResponse) String() string

func (*JobCancelResponse) XXX_DiscardUnknown 

func (m *JobCancelResponse) XXX_DiscardUnknown()

func (*JobCancelResponse) XXX_Marshal 

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

func (*JobCancelResponse) XXX_Merge 

func (m *JobCancelResponse) XXX_Merge(src proto.Message)

func (*JobCancelResponse) XXX_Size 

func (m *JobCancelResponse) XXX_Size() int

func (*JobCancelResponse) XXX_Unmarshal 

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

type JobListRequest 

type JobListRequest struct {
	AgentHost            string   `protobuf:"bytes,1,opt,name=agent_host,json=agentHost,proto3" json:"agent_host,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*JobListRequest) Descriptor 

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

func (*JobListRequest) GetAgentHost 

func (m *JobListRequest) GetAgentHost() string

func (*JobListRequest) ProtoMessage 

func (*JobListRequest) ProtoMessage()

func (*JobListRequest) Reset 

func (m *JobListRequest) Reset()

func (*JobListRequest) String 

func (m *JobListRequest) String() string

func (*JobListRequest) XXX_DiscardUnknown 

func (m *JobListRequest) XXX_DiscardUnknown()

func (*JobListRequest) XXX_Marshal 

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

func (*JobListRequest) XXX_Merge 

func (m *JobListRequest) XXX_Merge(src proto.Message)

func (*JobListRequest) XXX_Size 

func (m *JobListRequest) XXX_Size() int

func (*JobListRequest) XXX_Unmarshal 

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

type JobListResponse 

type JobListResponse struct {
	Jobs                 []*JobListResponse_Job `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*JobListResponse) Descriptor 

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

func (*JobListResponse) GetJobs 

func (m *JobListResponse) GetJobs() []*JobListResponse_Job

func (*JobListResponse) ProtoMessage 

func (*JobListResponse) ProtoMessage()

func (*JobListResponse) Reset 

func (m *JobListResponse) Reset()

func (*JobListResponse) String 

func (m *JobListResponse) String() string

func (*JobListResponse) XXX_DiscardUnknown 

func (m *JobListResponse) XXX_DiscardUnknown()

func (*JobListResponse) XXX_Marshal 

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

func (*JobListResponse) XXX_Merge 

func (m *JobListResponse) XXX_Merge(src proto.Message)

func (*JobListResponse) XXX_Size 

func (m *JobListResponse) XXX_Size() int

func (*JobListResponse) XXX_Unmarshal 

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

type JobListResponse_Job 

type JobListResponse_Job struct {
	Id                   uint32    `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                 string    `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	AgentHost            string    `protobuf:"bytes,3,opt,name=agent_host,json=agentHost,proto3" json:"agent_host,omitempty"`
	Status               JobStatus `protobuf:"varint,4,opt,name=status,proto3,enum=drlm.JobStatus" json:"status,omitempty"`
	Info                 string    `protobuf:"bytes,5,opt,name=info,proto3" json:"info,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*JobListResponse_Job) Descriptor 

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

func (*JobListResponse_Job) GetAgentHost 

func (m *JobListResponse_Job) GetAgentHost() string

func (*JobListResponse_Job) GetId 

func (m *JobListResponse_Job) GetId() uint32

func (*JobListResponse_Job) GetInfo 

func (m *JobListResponse_Job) GetInfo() string

func (*JobListResponse_Job) GetName 

func (m *JobListResponse_Job) GetName() string

func (*JobListResponse_Job) GetStatus 

func (m *JobListResponse_Job) GetStatus() JobStatus

func (*JobListResponse_Job) ProtoMessage 

func (*JobListResponse_Job) ProtoMessage()

func (*JobListResponse_Job) Reset 

func (m *JobListResponse_Job) Reset()

func (*JobListResponse_Job) String 

func (m *JobListResponse_Job) String() string

func (*JobListResponse_Job) XXX_DiscardUnknown 

func (m *JobListResponse_Job) XXX_DiscardUnknown()

func (*JobListResponse_Job) XXX_Marshal 

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

func (*JobListResponse_Job) XXX_Merge 

func (m *JobListResponse_Job) XXX_Merge(src proto.Message)

func (*JobListResponse_Job) XXX_Size 

func (m *JobListResponse_Job) XXX_Size() int

func (*JobListResponse_Job) XXX_Unmarshal 

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

type JobScheduleRequest 

type JobScheduleRequest struct {
	AgentHost            string               `protobuf:"bytes,1,opt,name=agent_host,json=agentHost,proto3" json:"agent_host,omitempty"`
	Name                 string               `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Config               string               `protobuf:"bytes,3,opt,name=config,proto3" json:"config,omitempty"`
	Time                 *timestamp.Timestamp `protobuf:"bytes,4,opt,name=time,proto3" json:"time,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*JobScheduleRequest) Descriptor 

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

func (*JobScheduleRequest) GetAgentHost 

func (m *JobScheduleRequest) GetAgentHost() string

func (*JobScheduleRequest) GetConfig 

func (m *JobScheduleRequest) GetConfig() string

func (*JobScheduleRequest) GetName 

func (m *JobScheduleRequest) GetName() string

func (*JobScheduleRequest) GetTime 

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

func (*JobScheduleRequest) ProtoMessage 

func (*JobScheduleRequest) ProtoMessage()

func (*JobScheduleRequest) Reset 

func (m *JobScheduleRequest) Reset()

func (*JobScheduleRequest) String 

func (m *JobScheduleRequest) String() string

func (*JobScheduleRequest) XXX_DiscardUnknown 

func (m *JobScheduleRequest) XXX_DiscardUnknown()

func (*JobScheduleRequest) XXX_Marshal 

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

func (*JobScheduleRequest) XXX_Merge 

func (m *JobScheduleRequest) XXX_Merge(src proto.Message)

func (*JobScheduleRequest) XXX_Size 

func (m *JobScheduleRequest) XXX_Size() int

func (*JobScheduleRequest) XXX_Unmarshal 

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

type JobScheduleResponse 

type JobScheduleResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*JobScheduleResponse) Descriptor 

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

func (*JobScheduleResponse) ProtoMessage 

func (*JobScheduleResponse) ProtoMessage()

func (*JobScheduleResponse) Reset 

func (m *JobScheduleResponse) Reset()

func (*JobScheduleResponse) String 

func (m *JobScheduleResponse) String() string

func (*JobScheduleResponse) XXX_DiscardUnknown 

func (m *JobScheduleResponse) XXX_DiscardUnknown()

func (*JobScheduleResponse) XXX_Marshal 

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

func (*JobScheduleResponse) XXX_Merge 

func (m *JobScheduleResponse) XXX_Merge(src proto.Message)

func (*JobScheduleResponse) XXX_Size 

func (m *JobScheduleResponse) XXX_Size() int

func (*JobScheduleResponse) XXX_Unmarshal 

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

type JobStatus 

type JobStatus int32
const (
	JobStatus_JOB_STATUS_UNKNOWN   JobStatus = 0
	JobStatus_JOB_STATUS_SCHEDULED JobStatus = 1
	JobStatus_JOB_STATUS_RUNNING   JobStatus = 2
	JobStatus_JOB_STATUS_FINISHED  JobStatus = 3
	JobStatus_JOB_STATUS_FAILED    JobStatus = 4
	JobStatus_JOB_STATUS_CANCELLED JobStatus = 5
)

func (JobStatus) EnumDescriptor 

func (JobStatus) EnumDescriptor() ([]byte, []int)

func (JobStatus) String 

func (x JobStatus) String() string

type OS 

type OS int32
const (
	OS_OS_UNKNOWN   OS = 0
	OS_OS_LINUX     OS = 1
	OS_OS_WINDOWS   OS = 2
	OS_OS_DARWIN    OS = 3
	OS_OS_AIX       OS = 4
	OS_OS_DRAGONFLY OS = 5
	OS_OS_FREEBSD   OS = 6
	OS_OS_NETBSD    OS = 7
	OS_OS_OPENBSD   OS = 8
	OS_OS_PLAN9     OS = 9
	OS_OS_SOLARIS   OS = 10
)

func (OS) EnumDescriptor 

func (OS) EnumDescriptor() ([]byte, []int)

func (OS) String 

func (x OS) String() string

type UnimplementedDRLMServer 

type UnimplementedDRLMServer struct {
}

UnimplementedDRLMServer can be embedded to have forward compatible implementations.

func (*UnimplementedDRLMServer) AgentAccept 

func (*UnimplementedDRLMServer) AgentAccept(ctx context.Context, req *AgentAcceptRequest) (*AgentAcceptResponse, error)

func (*UnimplementedDRLMServer) AgentAdd 

func (*UnimplementedDRLMServer) AgentAdd(ctx context.Context, req *AgentAddRequest) (*AgentAddResponse, error)

func (*UnimplementedDRLMServer) AgentConnection 

func (*UnimplementedDRLMServer) AgentConnection(srv DRLM_AgentConnectionServer) error

func (*UnimplementedDRLMServer) AgentDelete 

func (*UnimplementedDRLMServer) AgentDelete(ctx context.Context, req *AgentDeleteRequest) (*AgentDeleteResponse, error)

func (*UnimplementedDRLMServer) AgentGet 

func (*UnimplementedDRLMServer) AgentGet(ctx context.Context, req *AgentGetRequest) (*AgentGetResponse, error)

func (*UnimplementedDRLMServer) AgentInstall 

func (*UnimplementedDRLMServer) AgentInstall(srv DRLM_AgentInstallServer) error

func (*UnimplementedDRLMServer) AgentList 

func (*UnimplementedDRLMServer) AgentList(ctx context.Context, req *AgentListRequest) (*AgentListResponse, error)

func (*UnimplementedDRLMServer) AgentPluginAdd 

func (*UnimplementedDRLMServer) AgentPluginAdd(srv DRLM_AgentPluginAddServer) error

func (*UnimplementedDRLMServer) AgentPluginList 

func (*UnimplementedDRLMServer) AgentPluginList(ctx context.Context, req *AgentPluginListRequest) (*AgentPluginListResponse, error)

func (*UnimplementedDRLMServer) AgentPluginRemove 

func (*UnimplementedDRLMServer) AgentPluginRemove(ctx context.Context, req *AgentPluginRemoveRequest) (*AgentPluginRemoveResponse, error)

func (*UnimplementedDRLMServer) AgentPluginUpdate 

func (*UnimplementedDRLMServer) AgentPluginUpdate(srv DRLM_AgentPluginUpdateServer) error

func (*UnimplementedDRLMServer) AgentRequestList 

func (*UnimplementedDRLMServer) AgentRequestList(ctx context.Context, req *AgentRequestListRequest) (*AgentRequestListResponse, error)

func (*UnimplementedDRLMServer) JobCancel 

func (*UnimplementedDRLMServer) JobCancel(ctx context.Context, req *JobCancelRequest) (*JobCancelResponse, error)

func (*UnimplementedDRLMServer) JobList 

func (*UnimplementedDRLMServer) JobList(ctx context.Context, req *JobListRequest) (*JobListResponse, error)

func (*UnimplementedDRLMServer) JobSchedule 

func (*UnimplementedDRLMServer) JobSchedule(ctx context.Context, req *JobScheduleRequest) (*JobScheduleResponse, error)

func (*UnimplementedDRLMServer) UserAdd 

func (*UnimplementedDRLMServer) UserAdd(ctx context.Context, req *UserAddRequest) (*UserAddResponse, error)

func (*UnimplementedDRLMServer) UserDelete 

func (*UnimplementedDRLMServer) UserDelete(ctx context.Context, req *UserDeleteRequest) (*UserDeleteResponse, error)

func (*UnimplementedDRLMServer) UserList 

func (*UnimplementedDRLMServer) UserList(ctx context.Context, req *UserListRequest) (*UserListResponse, error)

func (*UnimplementedDRLMServer) UserLogin 

func (*UnimplementedDRLMServer) UserLogin(ctx context.Context, req *UserLoginRequest) (*UserLoginResponse, error)

func (*UnimplementedDRLMServer) UserTokenRenew 

func (*UnimplementedDRLMServer) UserTokenRenew(ctx context.Context, req *UserTokenRenewRequest) (*UserTokenRenewResponse, error)

type UserAddRequest 

type UserAddRequest struct {
	Usr                  string   `protobuf:"bytes,1,opt,name=usr,proto3" json:"usr,omitempty"`
	Pwd                  string   `protobuf:"bytes,2,opt,name=pwd,proto3" json:"pwd,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UserAddRequest) Descriptor 

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

func (*UserAddRequest) GetPwd 

func (m *UserAddRequest) GetPwd() string

func (*UserAddRequest) GetUsr 

func (m *UserAddRequest) GetUsr() string

func (*UserAddRequest) ProtoMessage 

func (*UserAddRequest) ProtoMessage()

func (*UserAddRequest) Reset 

func (m *UserAddRequest) Reset()

func (*UserAddRequest) String 

func (m *UserAddRequest) String() string

func (*UserAddRequest) XXX_DiscardUnknown 

func (m *UserAddRequest) XXX_DiscardUnknown()

func (*UserAddRequest) XXX_Marshal 

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

func (*UserAddRequest) XXX_Merge 

func (m *UserAddRequest) XXX_Merge(src proto.Message)

func (*UserAddRequest) XXX_Size 

func (m *UserAddRequest) XXX_Size() int

func (*UserAddRequest) XXX_Unmarshal 

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

type UserAddResponse 

type UserAddResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UserAddResponse) Descriptor 

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

func (*UserAddResponse) ProtoMessage 

func (*UserAddResponse) ProtoMessage()

func (*UserAddResponse) Reset 

func (m *UserAddResponse) Reset()

func (*UserAddResponse) String 

func (m *UserAddResponse) String() string

func (*UserAddResponse) XXX_DiscardUnknown 

func (m *UserAddResponse) XXX_DiscardUnknown()

func (*UserAddResponse) XXX_Marshal 

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

func (*UserAddResponse) XXX_Merge 

func (m *UserAddResponse) XXX_Merge(src proto.Message)

func (*UserAddResponse) XXX_Size 

func (m *UserAddResponse) XXX_Size() int

func (*UserAddResponse) XXX_Unmarshal 

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

type UserDeleteRequest 

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

func (*UserDeleteRequest) Descriptor 

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

func (*UserDeleteRequest) GetUsr 

func (m *UserDeleteRequest) GetUsr() string

func (*UserDeleteRequest) ProtoMessage 

func (*UserDeleteRequest) ProtoMessage()

func (*UserDeleteRequest) Reset 

func (m *UserDeleteRequest) Reset()

func (*UserDeleteRequest) String 

func (m *UserDeleteRequest) String() string

func (*UserDeleteRequest) XXX_DiscardUnknown 

func (m *UserDeleteRequest) XXX_DiscardUnknown()

func (*UserDeleteRequest) XXX_Marshal 

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

func (*UserDeleteRequest) XXX_Merge 

func (m *UserDeleteRequest) XXX_Merge(src proto.Message)

func (*UserDeleteRequest) XXX_Size 

func (m *UserDeleteRequest) XXX_Size() int

func (*UserDeleteRequest) XXX_Unmarshal 

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

type UserDeleteResponse 

type UserDeleteResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UserDeleteResponse) Descriptor 

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

func (*UserDeleteResponse) ProtoMessage 

func (*UserDeleteResponse) ProtoMessage()

func (*UserDeleteResponse) Reset 

func (m *UserDeleteResponse) Reset()

func (*UserDeleteResponse) String 

func (m *UserDeleteResponse) String() string

func (*UserDeleteResponse) XXX_DiscardUnknown 

func (m *UserDeleteResponse) XXX_DiscardUnknown()

func (*UserDeleteResponse) XXX_Marshal 

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

func (*UserDeleteResponse) XXX_Merge 

func (m *UserDeleteResponse) XXX_Merge(src proto.Message)

func (*UserDeleteResponse) XXX_Size 

func (m *UserDeleteResponse) XXX_Size() int

func (*UserDeleteResponse) XXX_Unmarshal 

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

type UserListRequest 

type UserListRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UserListRequest) Descriptor 

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

func (*UserListRequest) ProtoMessage 

func (*UserListRequest) ProtoMessage()

func (*UserListRequest) Reset 

func (m *UserListRequest) Reset()

func (*UserListRequest) String 

func (m *UserListRequest) String() string

func (*UserListRequest) XXX_DiscardUnknown 

func (m *UserListRequest) XXX_DiscardUnknown()

func (*UserListRequest) XXX_Marshal 

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

func (*UserListRequest) XXX_Merge 

func (m *UserListRequest) XXX_Merge(src proto.Message)

func (*UserListRequest) XXX_Size 

func (m *UserListRequest) XXX_Size() int

func (*UserListRequest) XXX_Unmarshal 

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

type UserListResponse 

type UserListResponse struct {
	Users                []*UserListResponse_User `protobuf:"bytes,1,rep,name=users,proto3" json:"users,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*UserListResponse) Descriptor 

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

func (*UserListResponse) GetUsers 

func (m *UserListResponse) GetUsers() []*UserListResponse_User

func (*UserListResponse) ProtoMessage 

func (*UserListResponse) ProtoMessage()

func (*UserListResponse) Reset 

func (m *UserListResponse) Reset()

func (*UserListResponse) String 

func (m *UserListResponse) String() string

func (*UserListResponse) XXX_DiscardUnknown 

func (m *UserListResponse) XXX_DiscardUnknown()

func (*UserListResponse) XXX_Marshal 

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

func (*UserListResponse) XXX_Merge 

func (m *UserListResponse) XXX_Merge(src proto.Message)

func (*UserListResponse) XXX_Size 

func (m *UserListResponse) XXX_Size() int

func (*UserListResponse) XXX_Unmarshal 

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

type UserListResponse_User 

type UserListResponse_User struct {
	Usr                  string               `protobuf:"bytes,1,opt,name=usr,proto3" json:"usr,omitempty"`
	AuthType             AuthType             `protobuf:"varint,2,opt,name=auth_type,json=authType,proto3,enum=drlm.AuthType" json:"auth_type,omitempty"`
	CreatedAt            *timestamp.Timestamp `protobuf:"bytes,3,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt            *timestamp.Timestamp `protobuf:"bytes,4,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*UserListResponse_User) Descriptor 

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

func (*UserListResponse_User) GetAuthType 

func (m *UserListResponse_User) GetAuthType() AuthType

func (*UserListResponse_User) GetCreatedAt 

func (m *UserListResponse_User) GetCreatedAt() *timestamp.Timestamp

func (*UserListResponse_User) GetUpdatedAt 

func (m *UserListResponse_User) GetUpdatedAt() *timestamp.Timestamp

func (*UserListResponse_User) GetUsr 

func (m *UserListResponse_User) GetUsr() string

func (*UserListResponse_User) ProtoMessage 

func (*UserListResponse_User) ProtoMessage()

func (*UserListResponse_User) Reset 

func (m *UserListResponse_User) Reset()

func (*UserListResponse_User) String 

func (m *UserListResponse_User) String() string

func (*UserListResponse_User) XXX_DiscardUnknown 

func (m *UserListResponse_User) XXX_DiscardUnknown()

func (*UserListResponse_User) XXX_Marshal 

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

func (*UserListResponse_User) XXX_Merge 

func (m *UserListResponse_User) XXX_Merge(src proto.Message)

func (*UserListResponse_User) XXX_Size 

func (m *UserListResponse_User) XXX_Size() int

func (*UserListResponse_User) XXX_Unmarshal 

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

type UserLoginRequest 

type UserLoginRequest struct {
	Usr                  string   `protobuf:"bytes,1,opt,name=usr,proto3" json:"usr,omitempty"`
	Pwd                  string   `protobuf:"bytes,2,opt,name=pwd,proto3" json:"pwd,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UserLoginRequest) Descriptor 

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

func (*UserLoginRequest) GetPwd 

func (m *UserLoginRequest) GetPwd() string

func (*UserLoginRequest) GetUsr 

func (m *UserLoginRequest) GetUsr() string

func (*UserLoginRequest) ProtoMessage 

func (*UserLoginRequest) ProtoMessage()

func (*UserLoginRequest) Reset 

func (m *UserLoginRequest) Reset()

func (*UserLoginRequest) String 

func (m *UserLoginRequest) String() string

func (*UserLoginRequest) XXX_DiscardUnknown 

func (m *UserLoginRequest) XXX_DiscardUnknown()

func (*UserLoginRequest) XXX_Marshal 

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

func (*UserLoginRequest) XXX_Merge 

func (m *UserLoginRequest) XXX_Merge(src proto.Message)

func (*UserLoginRequest) XXX_Size 

func (m *UserLoginRequest) XXX_Size() int

func (*UserLoginRequest) XXX_Unmarshal 

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

type UserLoginResponse 

type UserLoginResponse struct {
	Tkn                  string               `protobuf:"bytes,1,opt,name=tkn,proto3" json:"tkn,omitempty"`
	TknExpiration        *timestamp.Timestamp `protobuf:"bytes,2,opt,name=tkn_expiration,json=tknExpiration,proto3" json:"tkn_expiration,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*UserLoginResponse) Descriptor 

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

func (*UserLoginResponse) GetTkn 

func (m *UserLoginResponse) GetTkn() string

func (*UserLoginResponse) GetTknExpiration 

func (m *UserLoginResponse) GetTknExpiration() *timestamp.Timestamp

func (*UserLoginResponse) ProtoMessage 

func (*UserLoginResponse) ProtoMessage()

func (*UserLoginResponse) Reset 

func (m *UserLoginResponse) Reset()

func (*UserLoginResponse) String 

func (m *UserLoginResponse) String() string

func (*UserLoginResponse) XXX_DiscardUnknown 

func (m *UserLoginResponse) XXX_DiscardUnknown()

func (*UserLoginResponse) XXX_Marshal 

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

func (*UserLoginResponse) XXX_Merge 

func (m *UserLoginResponse) XXX_Merge(src proto.Message)

func (*UserLoginResponse) XXX_Size 

func (m *UserLoginResponse) XXX_Size() int

func (*UserLoginResponse) XXX_Unmarshal 

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

type UserTokenRenewRequest 

type UserTokenRenewRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UserTokenRenewRequest) Descriptor 

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

func (*UserTokenRenewRequest) ProtoMessage 

func (*UserTokenRenewRequest) ProtoMessage()

func (*UserTokenRenewRequest) Reset 

func (m *UserTokenRenewRequest) Reset()

func (*UserTokenRenewRequest) String 

func (m *UserTokenRenewRequest) String() string

func (*UserTokenRenewRequest) XXX_DiscardUnknown 

func (m *UserTokenRenewRequest) XXX_DiscardUnknown()

func (*UserTokenRenewRequest) XXX_Marshal 

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

func (*UserTokenRenewRequest) XXX_Merge 

func (m *UserTokenRenewRequest) XXX_Merge(src proto.Message)

func (*UserTokenRenewRequest) XXX_Size 

func (m *UserTokenRenewRequest) XXX_Size() int

func (*UserTokenRenewRequest) XXX_Unmarshal 

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

type UserTokenRenewResponse 

type UserTokenRenewResponse struct {
	Tkn                  string               `protobuf:"bytes,1,opt,name=tkn,proto3" json:"tkn,omitempty"`
	TknExpiration        *timestamp.Timestamp `protobuf:"bytes,2,opt,name=tkn_expiration,json=tknExpiration,proto3" json:"tkn_expiration,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*UserTokenRenewResponse) Descriptor 

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

func (*UserTokenRenewResponse) GetTkn 

func (m *UserTokenRenewResponse) GetTkn() string

func (*UserTokenRenewResponse) GetTknExpiration 

func (m *UserTokenRenewResponse) GetTknExpiration() *timestamp.Timestamp

func (*UserTokenRenewResponse) ProtoMessage 

func (*UserTokenRenewResponse) ProtoMessage()

func (*UserTokenRenewResponse) Reset 

func (m *UserTokenRenewResponse) Reset()

func (*UserTokenRenewResponse) String 

func (m *UserTokenRenewResponse) String() string

func (*UserTokenRenewResponse) XXX_DiscardUnknown 

func (m *UserTokenRenewResponse) XXX_DiscardUnknown()

func (*UserTokenRenewResponse) XXX_Marshal 

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

func (*UserTokenRenewResponse) XXX_Merge 

func (m *UserTokenRenewResponse) XXX_Merge(src proto.Message)

func (*UserTokenRenewResponse) XXX_Size 

func (m *UserTokenRenewResponse) XXX_Size() int

func (*UserTokenRenewResponse) XXX_Unmarshal 

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

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.