manager

package
v0.0.0-...-0490640 Latest Latest
Warning

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

 Go to latest Published: May 16, 2019 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Overview

Package manager is a generated GoMock package.

Index

Constants

This section is empty.

Variables

View Source 
var NodeState_State_name = map[int32]string{
	0: "RUNNING",
	1: "STOPPED",
	2: "TERMINATED",
}
View Source 
var NodeState_State_value = map[string]int32{
	"RUNNING":    0,
	"STOPPED":    1,
	"TERMINATED": 2,
}
View Source 
var Query_OrderType_name = map[int32]string{
	0: "ASC",
	1: "DESC",
}
View Source 
var Query_OrderType_value = map[string]int32{
	"ASC":  0,
	"DESC": 1,
}

Functions

func RegisterNodeManagerServiceServer 

func RegisterNodeManagerServiceServer(s *grpc.Server, srv NodeManagerServiceServer)

Types

type ChangeNodeStateResponse 

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

func (*ChangeNodeStateResponse) Descriptor 

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

func (*ChangeNodeStateResponse) ProtoMessage 

func (*ChangeNodeStateResponse) ProtoMessage()

func (*ChangeNodeStateResponse) Reset 

func (m *ChangeNodeStateResponse) Reset()

func (*ChangeNodeStateResponse) String 

func (m *ChangeNodeStateResponse) String() string

func (*ChangeNodeStateResponse) XXX_DiscardUnknown 

func (m *ChangeNodeStateResponse) XXX_DiscardUnknown()

func (*ChangeNodeStateResponse) XXX_Marshal 

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

func (*ChangeNodeStateResponse) XXX_Merge 

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

func (*ChangeNodeStateResponse) XXX_Size 

func (m *ChangeNodeStateResponse) XXX_Size() int

func (*ChangeNodeStateResponse) XXX_Unmarshal 

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

type Credentials 

type Credentials struct {
	Credentials          string   `protobuf:"bytes,20,opt,name=credentials,proto3" json:"credentials,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Credentials) Descriptor 

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

func (*Credentials) GetCredentials 

func (m *Credentials) GetCredentials() string

func (*Credentials) ProtoMessage 

func (*Credentials) ProtoMessage()

func (*Credentials) Reset 

func (m *Credentials) Reset()

func (*Credentials) String 

func (m *Credentials) String() string

func (*Credentials) XXX_DiscardUnknown 

func (m *Credentials) XXX_DiscardUnknown()

func (*Credentials) XXX_Marshal 

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

func (*Credentials) XXX_Merge 

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

func (*Credentials) XXX_Size 

func (m *Credentials) XXX_Size() int

func (*Credentials) XXX_Unmarshal 

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

type CredentialsByTags 

type CredentialsByTags struct {
	TagKey               string   `protobuf:"bytes,20,opt,name=tag_key,json=tagKey,proto3" json:"tag_key,omitempty"`
	TagValue             string   `protobuf:"bytes,21,opt,name=tag_value,json=tagValue,proto3" json:"tag_value,omitempty"`
	CredentialIds        []string `protobuf:"bytes,22,rep,name=credential_ids,json=credentialIds,proto3" json:"credential_ids,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CredentialsByTags) Descriptor 

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

func (*CredentialsByTags) GetCredentialIds 

func (m *CredentialsByTags) GetCredentialIds() []string

func (*CredentialsByTags) GetTagKey 

func (m *CredentialsByTags) GetTagKey() string

func (*CredentialsByTags) GetTagValue 

func (m *CredentialsByTags) GetTagValue() string

func (*CredentialsByTags) ProtoMessage 

func (*CredentialsByTags) ProtoMessage()

func (*CredentialsByTags) Reset 

func (m *CredentialsByTags) Reset()

func (*CredentialsByTags) String 

func (m *CredentialsByTags) String() string

func (*CredentialsByTags) XXX_DiscardUnknown 

func (m *CredentialsByTags) XXX_DiscardUnknown()

func (*CredentialsByTags) XXX_Marshal 

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

func (*CredentialsByTags) XXX_Merge 

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

func (*CredentialsByTags) XXX_Size 

func (m *CredentialsByTags) XXX_Size() int

func (*CredentialsByTags) XXX_Unmarshal 

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

type FieldQuery 

type FieldQuery struct {
	Query                *Query   `protobuf:"bytes,20,opt,name=query,proto3" json:"query,omitempty"`
	Field                string   `protobuf:"bytes,21,opt,name=field,proto3" json:"field,omitempty"`
	NodeManagerId        string   `protobuf:"bytes,22,opt,name=node_manager_id,json=nodeManagerId,proto3" json:"node_manager_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FieldQuery) Descriptor 

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

func (*FieldQuery) GetField 

func (m *FieldQuery) GetField() string

func (*FieldQuery) GetNodeManagerId 

func (m *FieldQuery) GetNodeManagerId() string

func (*FieldQuery) GetQuery 

func (m *FieldQuery) GetQuery() *Query

func (*FieldQuery) ProtoMessage 

func (*FieldQuery) ProtoMessage()

func (*FieldQuery) Reset 

func (m *FieldQuery) Reset()

func (*FieldQuery) String 

func (m *FieldQuery) String() string

func (*FieldQuery) XXX_DiscardUnknown 

func (m *FieldQuery) XXX_DiscardUnknown()

func (*FieldQuery) XXX_Marshal 

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

func (*FieldQuery) XXX_Merge 

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

func (*FieldQuery) XXX_Size 

func (m *FieldQuery) XXX_Size() int

func (*FieldQuery) XXX_Unmarshal 

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

type Fields 

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

func (*Fields) Descriptor 

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

func (*Fields) GetFields 

func (m *Fields) GetFields() []string

func (*Fields) ProtoMessage 

func (*Fields) ProtoMessage()

func (*Fields) Reset 

func (m *Fields) Reset()

func (*Fields) String 

func (m *Fields) String() string

func (*Fields) XXX_DiscardUnknown 

func (m *Fields) XXX_DiscardUnknown()

func (*Fields) XXX_Marshal 

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

func (*Fields) XXX_Merge 

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

func (*Fields) XXX_Size 

func (m *Fields) XXX_Size() int

func (*Fields) XXX_Unmarshal 

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

type Id 

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

func (*Id) Descriptor 

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

func (*Id) GetId 

func (m *Id) GetId() string

func (*Id) ProtoMessage 

func (*Id) ProtoMessage()

func (*Id) Reset 

func (m *Id) Reset()

func (*Id) String 

func (m *Id) String() string

func (*Id) XXX_DiscardUnknown 

func (m *Id) XXX_DiscardUnknown()

func (*Id) XXX_Marshal 

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

func (*Id) XXX_Merge 

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

func (*Id) XXX_Size 

func (m *Id) XXX_Size() int

func (*Id) XXX_Unmarshal 

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

type Ids 

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

func (*Ids) Descriptor 

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

func (*Ids) GetIds 

func (m *Ids) GetIds() []*Id

func (*Ids) ProtoMessage 

func (*Ids) ProtoMessage()

func (*Ids) Reset 

func (m *Ids) Reset()

func (*Ids) String 

func (m *Ids) String() string

func (*Ids) XXX_DiscardUnknown 

func (m *Ids) XXX_DiscardUnknown()

func (*Ids) XXX_Marshal 

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

func (*Ids) XXX_Merge 

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

func (*Ids) XXX_Size 

func (m *Ids) XXX_Size() int

func (*Ids) XXX_Unmarshal 

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

type ManagerNode 

type ManagerNode struct {
	Id       string       `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Host     string       `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"`
	PublicIp string       `protobuf:"bytes,3,opt,name=public_ip,json=publicIp,proto3" json:"public_ip,omitempty"`
	Tags     []*common.Kv `protobuf:"bytes,4,rep,name=tags,proto3" json:"tags,omitempty"`
	Platform string       `protobuf:"bytes,5,opt,name=platform,proto3" json:"platform,omitempty"`
	// should all these be tags??
	Region               string   `protobuf:"bytes,6,opt,name=region,proto3" json:"region,omitempty"`
	Name                 string   `protobuf:"bytes,7,opt,name=name,proto3" json:"name,omitempty"`
	Ssm                  string   `protobuf:"bytes,8,opt,name=ssm,proto3" json:"ssm,omitempty"`
	Uuid                 string   `protobuf:"bytes,9,opt,name=uuid,proto3" json:"uuid,omitempty"`
	MachineIdentifier    string   `protobuf:"bytes,10,opt,name=machine_identifier,json=machineIdentifier,proto3" json:"machine_identifier,omitempty"`
	Group                string   `protobuf:"bytes,11,opt,name=group,proto3" json:"group,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ManagerNode) Descriptor 

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

func (*ManagerNode) GetGroup 

func (m *ManagerNode) GetGroup() string

func (*ManagerNode) GetHost 

func (m *ManagerNode) GetHost() string

func (*ManagerNode) GetId 

func (m *ManagerNode) GetId() string

func (*ManagerNode) GetMachineIdentifier 

func (m *ManagerNode) GetMachineIdentifier() string

func (*ManagerNode) GetName 

func (m *ManagerNode) GetName() string

func (*ManagerNode) GetPlatform 

func (m *ManagerNode) GetPlatform() string

func (*ManagerNode) GetPublicIp 

func (m *ManagerNode) GetPublicIp() string

func (*ManagerNode) GetRegion 

func (m *ManagerNode) GetRegion() string

func (*ManagerNode) GetSsm 

func (m *ManagerNode) GetSsm() string

func (*ManagerNode) GetTags 

func (m *ManagerNode) GetTags() []*common.Kv

func (*ManagerNode) GetUuid 

func (m *ManagerNode) GetUuid() string

func (*ManagerNode) ProtoMessage 

func (*ManagerNode) ProtoMessage()

func (*ManagerNode) Reset 

func (m *ManagerNode) Reset()

func (*ManagerNode) String 

func (m *ManagerNode) String() string

func (*ManagerNode) XXX_DiscardUnknown 

func (m *ManagerNode) XXX_DiscardUnknown()

func (*ManagerNode) XXX_Marshal 

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

func (*ManagerNode) XXX_Merge 

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

func (*ManagerNode) XXX_Size 

func (m *ManagerNode) XXX_Size() int

func (*ManagerNode) XXX_Unmarshal 

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

type ManagerNodes 

type ManagerNodes struct {
	Nodes                []*ManagerNode `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*ManagerNodes) Descriptor 

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

func (*ManagerNodes) GetNodes 

func (m *ManagerNodes) GetNodes() []*ManagerNode

func (*ManagerNodes) ProtoMessage 

func (*ManagerNodes) ProtoMessage()

func (*ManagerNodes) Reset 

func (m *ManagerNodes) Reset()

func (*ManagerNodes) String 

func (m *ManagerNodes) String() string

func (*ManagerNodes) XXX_DiscardUnknown 

func (m *ManagerNodes) XXX_DiscardUnknown()

func (*ManagerNodes) XXX_Marshal 

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

func (*ManagerNodes) XXX_Merge 

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

func (*ManagerNodes) XXX_Size 

func (m *ManagerNodes) XXX_Size() int

func (*ManagerNodes) XXX_Unmarshal 

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

type MockNodeManagerServiceClient 

type MockNodeManagerServiceClient struct {
	// contains filtered or unexported fields
}

MockNodeManagerServiceClient is a mock of NodeManagerServiceClient interface

func NewMockNodeManagerServiceClient 

func NewMockNodeManagerServiceClient(ctrl *gomock.Controller) *MockNodeManagerServiceClient

NewMockNodeManagerServiceClient creates a new mock instance

func (*MockNodeManagerServiceClient) ChangeNodeState 

func (m *MockNodeManagerServiceClient) ChangeNodeState(ctx context.Context, in *NodeState, opts ...grpc.CallOption) (*ChangeNodeStateResponse, error)

ChangeNodeState mocks base method

func (*MockNodeManagerServiceClient) Connect 

func (m *MockNodeManagerServiceClient) Connect(ctx context.Context, in *NodeManager, opts ...grpc.CallOption) (*empty.Empty, error)

Connect mocks base method

func (*MockNodeManagerServiceClient) ConnectManager 

func (m *MockNodeManagerServiceClient) ConnectManager(ctx context.Context, in *Id, opts ...grpc.CallOption) (*empty.Empty, error)

ConnectManager mocks base method

func (*MockNodeManagerServiceClient) Create 

func (m *MockNodeManagerServiceClient) Create(ctx context.Context, in *NodeManager, opts ...grpc.CallOption) (*Ids, error)

Create mocks base method

func (*MockNodeManagerServiceClient) Delete 

func (m *MockNodeManagerServiceClient) Delete(ctx context.Context, in *Id, opts ...grpc.CallOption) (*empty.Empty, error)

Delete mocks base method

func (*MockNodeManagerServiceClient) DeleteWithNodeStateStopped 

func (m *MockNodeManagerServiceClient) DeleteWithNodeStateStopped(ctx context.Context, in *Id, opts ...grpc.CallOption) (*empty.Empty, error)

DeleteWithNodeStateStopped mocks base method

func (*MockNodeManagerServiceClient) DeleteWithNodeStateTerminated 

func (m *MockNodeManagerServiceClient) DeleteWithNodeStateTerminated(ctx context.Context, in *Id, opts ...grpc.CallOption) (*empty.Empty, error)

DeleteWithNodeStateTerminated mocks base method

func (*MockNodeManagerServiceClient) DeleteWithNodes 

func (m *MockNodeManagerServiceClient) DeleteWithNodes(ctx context.Context, in *Id, opts ...grpc.CallOption) (*Ids, error)

DeleteWithNodes mocks base method

func (*MockNodeManagerServiceClient) EXPECT 

func (m *MockNodeManagerServiceClient) EXPECT() *MockNodeManagerServiceClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockNodeManagerServiceClient) GetNodeWithSecrets 

func (m *MockNodeManagerServiceClient) GetNodeWithSecrets(ctx context.Context, in *Id, opts ...grpc.CallOption) (*nodes.Node, error)

GetNodeWithSecrets mocks base method

func (*MockNodeManagerServiceClient) List 

func (m *MockNodeManagerServiceClient) List(ctx context.Context, in *Query, opts ...grpc.CallOption) (*NodeManagers, error)

List mocks base method

func (*MockNodeManagerServiceClient) ProcessNode 

func (m *MockNodeManagerServiceClient) ProcessNode(ctx context.Context, in *NodeMetadata, opts ...grpc.CallOption) (*ProcessNodeResponse, error)

ProcessNode mocks base method

func (*MockNodeManagerServiceClient) Read 

func (m *MockNodeManagerServiceClient) Read(ctx context.Context, in *Id, opts ...grpc.CallOption) (*NodeManager, error)

Read mocks base method

func (*MockNodeManagerServiceClient) SearchManagerNodes 

func (m *MockNodeManagerServiceClient) SearchManagerNodes(ctx context.Context, in *NodeQuery, opts ...grpc.CallOption) (*ManagerNodes, error)

SearchManagerNodes mocks base method

func (*MockNodeManagerServiceClient) SearchNodeFields 

func (m *MockNodeManagerServiceClient) SearchNodeFields(ctx context.Context, in *FieldQuery, opts ...grpc.CallOption) (*Fields, error)

SearchNodeFields mocks base method

func (*MockNodeManagerServiceClient) SearchNodes 

func (m *MockNodeManagerServiceClient) SearchNodes(ctx context.Context, in *NodeQuery, opts ...grpc.CallOption) (*Nodes, error)

SearchNodes mocks base method

func (*MockNodeManagerServiceClient) Update 

func (m *MockNodeManagerServiceClient) Update(ctx context.Context, in *NodeManager, opts ...grpc.CallOption) (*empty.Empty, error)

Update mocks base method

type MockNodeManagerServiceClientMockRecorder 

type MockNodeManagerServiceClientMockRecorder struct {
	// contains filtered or unexported fields
}

MockNodeManagerServiceClientMockRecorder is the mock recorder for MockNodeManagerServiceClient

func (*MockNodeManagerServiceClientMockRecorder) ChangeNodeState 

func (mr *MockNodeManagerServiceClientMockRecorder) ChangeNodeState(ctx, in interface{}, opts ...interface{}) *gomock.Call

ChangeNodeState indicates an expected call of ChangeNodeState

func (*MockNodeManagerServiceClientMockRecorder) Connect 

func (mr *MockNodeManagerServiceClientMockRecorder) Connect(ctx, in interface{}, opts ...interface{}) *gomock.Call

Connect indicates an expected call of Connect

func (*MockNodeManagerServiceClientMockRecorder) ConnectManager 

func (mr *MockNodeManagerServiceClientMockRecorder) ConnectManager(ctx, in interface{}, opts ...interface{}) *gomock.Call

ConnectManager indicates an expected call of ConnectManager

func (*MockNodeManagerServiceClientMockRecorder) Create 

func (mr *MockNodeManagerServiceClientMockRecorder) Create(ctx, in interface{}, opts ...interface{}) *gomock.Call

Create indicates an expected call of Create

func (*MockNodeManagerServiceClientMockRecorder) Delete 

func (mr *MockNodeManagerServiceClientMockRecorder) Delete(ctx, in interface{}, opts ...interface{}) *gomock.Call

Delete indicates an expected call of Delete

func (*MockNodeManagerServiceClientMockRecorder) DeleteWithNodeStateStopped 

func (mr *MockNodeManagerServiceClientMockRecorder) DeleteWithNodeStateStopped(ctx, in interface{}, opts ...interface{}) *gomock.Call

DeleteWithNodeStateStopped indicates an expected call of DeleteWithNodeStateStopped

func (*MockNodeManagerServiceClientMockRecorder) DeleteWithNodeStateTerminated 

func (mr *MockNodeManagerServiceClientMockRecorder) DeleteWithNodeStateTerminated(ctx, in interface{}, opts ...interface{}) *gomock.Call

DeleteWithNodeStateTerminated indicates an expected call of DeleteWithNodeStateTerminated

func (*MockNodeManagerServiceClientMockRecorder) DeleteWithNodes 

func (mr *MockNodeManagerServiceClientMockRecorder) DeleteWithNodes(ctx, in interface{}, opts ...interface{}) *gomock.Call

DeleteWithNodes indicates an expected call of DeleteWithNodes

func (*MockNodeManagerServiceClientMockRecorder) GetNodeWithSecrets 

func (mr *MockNodeManagerServiceClientMockRecorder) GetNodeWithSecrets(ctx, in interface{}, opts ...interface{}) *gomock.Call

GetNodeWithSecrets indicates an expected call of GetNodeWithSecrets

func (*MockNodeManagerServiceClientMockRecorder) List 

func (mr *MockNodeManagerServiceClientMockRecorder) List(ctx, in interface{}, opts ...interface{}) *gomock.Call

List indicates an expected call of List

func (*MockNodeManagerServiceClientMockRecorder) ProcessNode 

func (mr *MockNodeManagerServiceClientMockRecorder) ProcessNode(ctx, in interface{}, opts ...interface{}) *gomock.Call

ProcessNode indicates an expected call of ProcessNode

func (*MockNodeManagerServiceClientMockRecorder) Read 

func (mr *MockNodeManagerServiceClientMockRecorder) Read(ctx, in interface{}, opts ...interface{}) *gomock.Call

Read indicates an expected call of Read

func (*MockNodeManagerServiceClientMockRecorder) SearchManagerNodes 

func (mr *MockNodeManagerServiceClientMockRecorder) SearchManagerNodes(ctx, in interface{}, opts ...interface{}) *gomock.Call

SearchManagerNodes indicates an expected call of SearchManagerNodes

func (*MockNodeManagerServiceClientMockRecorder) SearchNodeFields 

func (mr *MockNodeManagerServiceClientMockRecorder) SearchNodeFields(ctx, in interface{}, opts ...interface{}) *gomock.Call

SearchNodeFields indicates an expected call of SearchNodeFields

func (*MockNodeManagerServiceClientMockRecorder) SearchNodes 

func (mr *MockNodeManagerServiceClientMockRecorder) SearchNodes(ctx, in interface{}, opts ...interface{}) *gomock.Call

SearchNodes indicates an expected call of SearchNodes

func (*MockNodeManagerServiceClientMockRecorder) Update 

func (mr *MockNodeManagerServiceClientMockRecorder) Update(ctx, in interface{}, opts ...interface{}) *gomock.Call

Update indicates an expected call of Update

type MockNodeManagerServiceServer 

type MockNodeManagerServiceServer struct {
	// contains filtered or unexported fields
}

MockNodeManagerServiceServer is a mock of NodeManagerServiceServer interface

func NewMockNodeManagerServiceServer 

func NewMockNodeManagerServiceServer(ctrl *gomock.Controller) *MockNodeManagerServiceServer

NewMockNodeManagerServiceServer creates a new mock instance

func (*MockNodeManagerServiceServer) ChangeNodeState 

func (m *MockNodeManagerServiceServer) ChangeNodeState(arg0 context.Context, arg1 *NodeState) (*ChangeNodeStateResponse, error)

ChangeNodeState mocks base method

func (*MockNodeManagerServiceServer) Connect 

func (m *MockNodeManagerServiceServer) Connect(arg0 context.Context, arg1 *NodeManager) (*empty.Empty, error)

Connect mocks base method

func (*MockNodeManagerServiceServer) ConnectManager 

func (m *MockNodeManagerServiceServer) ConnectManager(arg0 context.Context, arg1 *Id) (*empty.Empty, error)

ConnectManager mocks base method

func (*MockNodeManagerServiceServer) Create 

func (m *MockNodeManagerServiceServer) Create(arg0 context.Context, arg1 *NodeManager) (*Ids, error)

Create mocks base method

func (*MockNodeManagerServiceServer) Delete 

func (m *MockNodeManagerServiceServer) Delete(arg0 context.Context, arg1 *Id) (*empty.Empty, error)

Delete mocks base method

func (*MockNodeManagerServiceServer) DeleteWithNodeStateStopped 

func (m *MockNodeManagerServiceServer) DeleteWithNodeStateStopped(arg0 context.Context, arg1 *Id) (*empty.Empty, error)

DeleteWithNodeStateStopped mocks base method

func (*MockNodeManagerServiceServer) DeleteWithNodeStateTerminated 

func (m *MockNodeManagerServiceServer) DeleteWithNodeStateTerminated(arg0 context.Context, arg1 *Id) (*empty.Empty, error)

DeleteWithNodeStateTerminated mocks base method

func (*MockNodeManagerServiceServer) DeleteWithNodes 

func (m *MockNodeManagerServiceServer) DeleteWithNodes(arg0 context.Context, arg1 *Id) (*Ids, error)

DeleteWithNodes mocks base method

func (*MockNodeManagerServiceServer) EXPECT 

func (m *MockNodeManagerServiceServer) EXPECT() *MockNodeManagerServiceServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockNodeManagerServiceServer) GetNodeWithSecrets 

func (m *MockNodeManagerServiceServer) GetNodeWithSecrets(arg0 context.Context, arg1 *Id) (*nodes.Node, error)

GetNodeWithSecrets mocks base method

func (*MockNodeManagerServiceServer) List 

func (m *MockNodeManagerServiceServer) List(arg0 context.Context, arg1 *Query) (*NodeManagers, error)

List mocks base method

func (*MockNodeManagerServiceServer) ProcessNode 

func (m *MockNodeManagerServiceServer) ProcessNode(arg0 context.Context, arg1 *NodeMetadata) (*ProcessNodeResponse, error)

ProcessNode mocks base method

func (*MockNodeManagerServiceServer) Read 

func (m *MockNodeManagerServiceServer) Read(arg0 context.Context, arg1 *Id) (*NodeManager, error)

Read mocks base method

func (*MockNodeManagerServiceServer) SearchManagerNodes 

func (m *MockNodeManagerServiceServer) SearchManagerNodes(arg0 context.Context, arg1 *NodeQuery) (*ManagerNodes, error)

SearchManagerNodes mocks base method

func (*MockNodeManagerServiceServer) SearchNodeFields 

func (m *MockNodeManagerServiceServer) SearchNodeFields(arg0 context.Context, arg1 *FieldQuery) (*Fields, error)

SearchNodeFields mocks base method

func (*MockNodeManagerServiceServer) SearchNodes 

func (m *MockNodeManagerServiceServer) SearchNodes(arg0 context.Context, arg1 *NodeQuery) (*Nodes, error)

SearchNodes mocks base method

func (*MockNodeManagerServiceServer) Update 

func (m *MockNodeManagerServiceServer) Update(arg0 context.Context, arg1 *NodeManager) (*empty.Empty, error)

Update mocks base method

type MockNodeManagerServiceServerMockRecorder 

type MockNodeManagerServiceServerMockRecorder struct {
	// contains filtered or unexported fields
}

MockNodeManagerServiceServerMockRecorder is the mock recorder for MockNodeManagerServiceServer

func (*MockNodeManagerServiceServerMockRecorder) ChangeNodeState 

func (mr *MockNodeManagerServiceServerMockRecorder) ChangeNodeState(arg0, arg1 interface{}) *gomock.Call

ChangeNodeState indicates an expected call of ChangeNodeState

func (*MockNodeManagerServiceServerMockRecorder) Connect 

func (mr *MockNodeManagerServiceServerMockRecorder) Connect(arg0, arg1 interface{}) *gomock.Call

Connect indicates an expected call of Connect

func (*MockNodeManagerServiceServerMockRecorder) ConnectManager 

func (mr *MockNodeManagerServiceServerMockRecorder) ConnectManager(arg0, arg1 interface{}) *gomock.Call

ConnectManager indicates an expected call of ConnectManager

func (*MockNodeManagerServiceServerMockRecorder) Create 

func (mr *MockNodeManagerServiceServerMockRecorder) Create(arg0, arg1 interface{}) *gomock.Call

Create indicates an expected call of Create

func (*MockNodeManagerServiceServerMockRecorder) Delete 

func (mr *MockNodeManagerServiceServerMockRecorder) Delete(arg0, arg1 interface{}) *gomock.Call

Delete indicates an expected call of Delete

func (*MockNodeManagerServiceServerMockRecorder) DeleteWithNodeStateStopped 

func (mr *MockNodeManagerServiceServerMockRecorder) DeleteWithNodeStateStopped(arg0, arg1 interface{}) *gomock.Call

DeleteWithNodeStateStopped indicates an expected call of DeleteWithNodeStateStopped

func (*MockNodeManagerServiceServerMockRecorder) DeleteWithNodeStateTerminated 

func (mr *MockNodeManagerServiceServerMockRecorder) DeleteWithNodeStateTerminated(arg0, arg1 interface{}) *gomock.Call

DeleteWithNodeStateTerminated indicates an expected call of DeleteWithNodeStateTerminated

func (*MockNodeManagerServiceServerMockRecorder) DeleteWithNodes 

func (mr *MockNodeManagerServiceServerMockRecorder) DeleteWithNodes(arg0, arg1 interface{}) *gomock.Call

DeleteWithNodes indicates an expected call of DeleteWithNodes

func (*MockNodeManagerServiceServerMockRecorder) GetNodeWithSecrets 

func (mr *MockNodeManagerServiceServerMockRecorder) GetNodeWithSecrets(arg0, arg1 interface{}) *gomock.Call

GetNodeWithSecrets indicates an expected call of GetNodeWithSecrets

func (*MockNodeManagerServiceServerMockRecorder) List 

func (mr *MockNodeManagerServiceServerMockRecorder) List(arg0, arg1 interface{}) *gomock.Call

List indicates an expected call of List

func (*MockNodeManagerServiceServerMockRecorder) ProcessNode 

func (mr *MockNodeManagerServiceServerMockRecorder) ProcessNode(arg0, arg1 interface{}) *gomock.Call

ProcessNode indicates an expected call of ProcessNode

func (*MockNodeManagerServiceServerMockRecorder) Read 

func (mr *MockNodeManagerServiceServerMockRecorder) Read(arg0, arg1 interface{}) *gomock.Call

Read indicates an expected call of Read

func (*MockNodeManagerServiceServerMockRecorder) SearchManagerNodes 

func (mr *MockNodeManagerServiceServerMockRecorder) SearchManagerNodes(arg0, arg1 interface{}) *gomock.Call

SearchManagerNodes indicates an expected call of SearchManagerNodes

func (*MockNodeManagerServiceServerMockRecorder) SearchNodeFields 

func (mr *MockNodeManagerServiceServerMockRecorder) SearchNodeFields(arg0, arg1 interface{}) *gomock.Call

SearchNodeFields indicates an expected call of SearchNodeFields

func (*MockNodeManagerServiceServerMockRecorder) SearchNodes 

func (mr *MockNodeManagerServiceServerMockRecorder) SearchNodes(arg0, arg1 interface{}) *gomock.Call

SearchNodes indicates an expected call of SearchNodes

func (*MockNodeManagerServiceServerMockRecorder) Update 

func (mr *MockNodeManagerServiceServerMockRecorder) Update(arg0, arg1 interface{}) *gomock.Call

Update indicates an expected call of Update

type NodeManager 

type NodeManager struct {
	Id                   string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                 string               `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Type                 string               `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	CredentialId         string               `protobuf:"bytes,20,opt,name=credential_id,json=credentialId,proto3" json:"credential_id,omitempty"`
	InstanceCredentials  []*CredentialsByTags `protobuf:"bytes,21,rep,name=instance_credentials,json=instanceCredentials,proto3" json:"instance_credentials,omitempty"`
	Status               string               `protobuf:"bytes,22,opt,name=status,proto3" json:"status,omitempty"`
	AccountId            string               `protobuf:"bytes,24,opt,name=account_id,json=accountId,proto3" json:"account_id,omitempty"`
	DateAdded            *timestamp.Timestamp `protobuf:"bytes,25,opt,name=date_added,json=dateAdded,proto3" json:"date_added,omitempty"`
	CredentialData       []*common.Kv         `protobuf:"bytes,26,rep,name=credential_data,json=credentialData,proto3" json:"credential_data,omitempty"`
	AccountAlias         string               `protobuf:"bytes,27,opt,name=account_alias,json=accountAlias,proto3" json:"account_alias,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*NodeManager) Descriptor 

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

func (*NodeManager) GetAccountAlias 

func (m *NodeManager) GetAccountAlias() string

func (*NodeManager) GetAccountId 

func (m *NodeManager) GetAccountId() string

func (*NodeManager) GetCredentialData 

func (m *NodeManager) GetCredentialData() []*common.Kv

func (*NodeManager) GetCredentialId 

func (m *NodeManager) GetCredentialId() string

func (*NodeManager) GetDateAdded 

func (m *NodeManager) GetDateAdded() *timestamp.Timestamp

func (*NodeManager) GetId 

func (m *NodeManager) GetId() string

func (*NodeManager) GetInstanceCredentials 

func (m *NodeManager) GetInstanceCredentials() []*CredentialsByTags

func (*NodeManager) GetName 

func (m *NodeManager) GetName() string

func (*NodeManager) GetStatus 

func (m *NodeManager) GetStatus() string

func (*NodeManager) GetType 

func (m *NodeManager) GetType() string

func (*NodeManager) ProtoMessage 

func (*NodeManager) ProtoMessage()

func (*NodeManager) Reset 

func (m *NodeManager) Reset()

func (*NodeManager) String 

func (m *NodeManager) String() string

func (*NodeManager) XXX_DiscardUnknown 

func (m *NodeManager) XXX_DiscardUnknown()

func (*NodeManager) XXX_Marshal 

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

func (*NodeManager) XXX_Merge 

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

func (*NodeManager) XXX_Size 

func (m *NodeManager) XXX_Size() int

func (*NodeManager) XXX_Unmarshal 

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

type NodeManagerServiceClient 

type NodeManagerServiceClient interface {
	Create(ctx context.Context, in *NodeManager, opts ...grpc.CallOption) (*Ids, error)
	Read(ctx context.Context, in *Id, opts ...grpc.CallOption) (*NodeManager, error)
	Update(ctx context.Context, in *NodeManager, opts ...grpc.CallOption) (*empty.Empty, error)
	Delete(ctx context.Context, in *Id, opts ...grpc.CallOption) (*empty.Empty, error)
	DeleteWithNodes(ctx context.Context, in *Id, opts ...grpc.CallOption) (*Ids, error)
	DeleteWithNodeStateStopped(ctx context.Context, in *Id, opts ...grpc.CallOption) (*empty.Empty, error)
	DeleteWithNodeStateTerminated(ctx context.Context, in *Id, opts ...grpc.CallOption) (*empty.Empty, error)
	List(ctx context.Context, in *Query, opts ...grpc.CallOption) (*NodeManagers, error)
	Connect(ctx context.Context, in *NodeManager, opts ...grpc.CallOption) (*empty.Empty, error)
	ConnectManager(ctx context.Context, in *Id, opts ...grpc.CallOption) (*empty.Empty, error)
	SearchNodeFields(ctx context.Context, in *FieldQuery, opts ...grpc.CallOption) (*Fields, error)
	SearchNodes(ctx context.Context, in *NodeQuery, opts ...grpc.CallOption) (*Nodes, error)
	ProcessNode(ctx context.Context, in *NodeMetadata, opts ...grpc.CallOption) (*ProcessNodeResponse, error)
	ChangeNodeState(ctx context.Context, in *NodeState, opts ...grpc.CallOption) (*ChangeNodeStateResponse, error)
	GetNodeWithSecrets(ctx context.Context, in *Id, opts ...grpc.CallOption) (*nodes.Node, error)
	SearchManagerNodes(ctx context.Context, in *NodeQuery, opts ...grpc.CallOption) (*ManagerNodes, error)
}

NodeManagerServiceClient is the client API for NodeManagerService service.

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

func NewNodeManagerServiceClient 

func NewNodeManagerServiceClient(cc *grpc.ClientConn) NodeManagerServiceClient

type NodeManagerServiceServer 

type NodeManagerServiceServer interface {
	Create(context.Context, *NodeManager) (*Ids, error)
	Read(context.Context, *Id) (*NodeManager, error)
	Update(context.Context, *NodeManager) (*empty.Empty, error)
	Delete(context.Context, *Id) (*empty.Empty, error)
	DeleteWithNodes(context.Context, *Id) (*Ids, error)
	DeleteWithNodeStateStopped(context.Context, *Id) (*empty.Empty, error)
	DeleteWithNodeStateTerminated(context.Context, *Id) (*empty.Empty, error)
	List(context.Context, *Query) (*NodeManagers, error)
	Connect(context.Context, *NodeManager) (*empty.Empty, error)
	ConnectManager(context.Context, *Id) (*empty.Empty, error)
	SearchNodeFields(context.Context, *FieldQuery) (*Fields, error)
	SearchNodes(context.Context, *NodeQuery) (*Nodes, error)
	ProcessNode(context.Context, *NodeMetadata) (*ProcessNodeResponse, error)
	ChangeNodeState(context.Context, *NodeState) (*ChangeNodeStateResponse, error)
	GetNodeWithSecrets(context.Context, *Id) (*nodes.Node, error)
	SearchManagerNodes(context.Context, *NodeQuery) (*ManagerNodes, error)
}

NodeManagerServiceServer is the server API for NodeManagerService service.

type NodeManagers 

type NodeManagers struct {
	Managers             []*NodeManager `protobuf:"bytes,1,rep,name=managers,proto3" json:"managers,omitempty"`
	Total                int32          `protobuf:"varint,20,opt,name=total,proto3" json:"total,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*NodeManagers) Descriptor 

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

func (*NodeManagers) GetManagers 

func (m *NodeManagers) GetManagers() []*NodeManager

func (*NodeManagers) GetTotal 

func (m *NodeManagers) GetTotal() int32

func (*NodeManagers) ProtoMessage 

func (*NodeManagers) ProtoMessage()

func (*NodeManagers) Reset 

func (m *NodeManagers) Reset()

func (*NodeManagers) String 

func (m *NodeManagers) String() string

func (*NodeManagers) XXX_DiscardUnknown 

func (m *NodeManagers) XXX_DiscardUnknown()

func (*NodeManagers) XXX_Marshal 

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

func (*NodeManagers) XXX_Merge 

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

func (*NodeManagers) XXX_Size 

func (m *NodeManagers) XXX_Size() int

func (*NodeManagers) XXX_Unmarshal 

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

type NodeMetadata 

type NodeMetadata struct {
	Uuid                 string                 `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Name                 string                 `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	PlatformName         string                 `protobuf:"bytes,3,opt,name=platform_name,json=platformName,proto3" json:"platform_name,omitempty"`
	PlatformRelease      string                 `protobuf:"bytes,4,opt,name=platform_release,json=platformRelease,proto3" json:"platform_release,omitempty"`
	JobUuid              string                 `protobuf:"bytes,5,opt,name=job_uuid,json=jobUuid,proto3" json:"job_uuid,omitempty"`
	LastContact          *timestamp.Timestamp   `protobuf:"bytes,6,opt,name=last_contact,json=lastContact,proto3" json:"last_contact,omitempty"`
	SourceId             string                 `protobuf:"bytes,7,opt,name=source_id,json=sourceId,proto3" json:"source_id,omitempty"`
	SourceRegion         string                 `protobuf:"bytes,8,opt,name=source_region,json=sourceRegion,proto3" json:"source_region,omitempty"`
	SourceAccountId      string                 `protobuf:"bytes,9,opt,name=source_account_id,json=sourceAccountId,proto3" json:"source_account_id,omitempty"`
	Tags                 []*common.Kv           `protobuf:"bytes,10,rep,name=tags,proto3" json:"tags,omitempty"`
	RunData              *nodes.LastContactData `protobuf:"bytes,11,opt,name=run_data,json=runData,proto3" json:"run_data,omitempty"`
	ScanData             *nodes.LastContactData `protobuf:"bytes,12,opt,name=scan_data,json=scanData,proto3" json:"scan_data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*NodeMetadata) Descriptor 

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

func (*NodeMetadata) GetJobUuid 

func (m *NodeMetadata) GetJobUuid() string

func (*NodeMetadata) GetLastContact 

func (m *NodeMetadata) GetLastContact() *timestamp.Timestamp

func (*NodeMetadata) GetName 

func (m *NodeMetadata) GetName() string

func (*NodeMetadata) GetPlatformName 

func (m *NodeMetadata) GetPlatformName() string

func (*NodeMetadata) GetPlatformRelease 

func (m *NodeMetadata) GetPlatformRelease() string

func (*NodeMetadata) GetRunData 

func (m *NodeMetadata) GetRunData() *nodes.LastContactData

func (*NodeMetadata) GetScanData 

func (m *NodeMetadata) GetScanData() *nodes.LastContactData

func (*NodeMetadata) GetSourceAccountId 

func (m *NodeMetadata) GetSourceAccountId() string

func (*NodeMetadata) GetSourceId 

func (m *NodeMetadata) GetSourceId() string

func (*NodeMetadata) GetSourceRegion 

func (m *NodeMetadata) GetSourceRegion() string

func (*NodeMetadata) GetTags 

func (m *NodeMetadata) GetTags() []*common.Kv

func (*NodeMetadata) GetUuid 

func (m *NodeMetadata) GetUuid() string

func (*NodeMetadata) ProtoMessage 

func (*NodeMetadata) ProtoMessage()

func (*NodeMetadata) Reset 

func (m *NodeMetadata) Reset()

func (*NodeMetadata) String 

func (m *NodeMetadata) String() string

func (*NodeMetadata) XXX_DiscardUnknown 

func (m *NodeMetadata) XXX_DiscardUnknown()

func (*NodeMetadata) XXX_Marshal 

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

func (*NodeMetadata) XXX_Merge 

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

func (*NodeMetadata) XXX_Size 

func (m *NodeMetadata) XXX_Size() int

func (*NodeMetadata) XXX_Unmarshal 

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

type NodeQuery 

type NodeQuery struct {
	Query                *Query   `protobuf:"bytes,20,opt,name=query,proto3" json:"query,omitempty"`
	NodeManagerId        string   `protobuf:"bytes,21,opt,name=node_manager_id,json=nodeManagerId,proto3" json:"node_manager_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NodeQuery) Descriptor 

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

func (*NodeQuery) GetNodeManagerId 

func (m *NodeQuery) GetNodeManagerId() string

func (*NodeQuery) GetQuery 

func (m *NodeQuery) GetQuery() *Query

func (*NodeQuery) ProtoMessage 

func (*NodeQuery) ProtoMessage()

func (*NodeQuery) Reset 

func (m *NodeQuery) Reset()

func (*NodeQuery) String 

func (m *NodeQuery) String() string

func (*NodeQuery) XXX_DiscardUnknown 

func (m *NodeQuery) XXX_DiscardUnknown()

func (*NodeQuery) XXX_Marshal 

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

func (*NodeQuery) XXX_Merge 

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

func (*NodeQuery) XXX_Size 

func (m *NodeQuery) XXX_Size() int

func (*NodeQuery) XXX_Unmarshal 

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

type NodeState 

type NodeState struct {
	Id                   string          `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	State                NodeState_State `` /* 130-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*NodeState) Descriptor 

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

func (*NodeState) GetId 

func (m *NodeState) GetId() string

func (*NodeState) GetState 

func (m *NodeState) GetState() NodeState_State

func (*NodeState) ProtoMessage 

func (*NodeState) ProtoMessage()

func (*NodeState) Reset 

func (m *NodeState) Reset()

func (*NodeState) String 

func (m *NodeState) String() string

func (*NodeState) XXX_DiscardUnknown 

func (m *NodeState) XXX_DiscardUnknown()

func (*NodeState) XXX_Marshal 

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

func (*NodeState) XXX_Merge 

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

func (*NodeState) XXX_Size 

func (m *NodeState) XXX_Size() int

func (*NodeState) XXX_Unmarshal 

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

type NodeState_State 

type NodeState_State int32
const (
	NodeState_RUNNING    NodeState_State = 0
	NodeState_STOPPED    NodeState_State = 1
	NodeState_TERMINATED NodeState_State = 2
)

func (NodeState_State) EnumDescriptor 

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

func (NodeState_State) String 

func (x NodeState_State) String() string

type Nodes 

type Nodes struct {
	Nodes                []string `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
	Total                int32    `protobuf:"varint,20,opt,name=total,proto3" json:"total,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Nodes) Descriptor 

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

func (*Nodes) GetNodes 

func (m *Nodes) GetNodes() []string

func (*Nodes) GetTotal 

func (m *Nodes) GetTotal() int32

func (*Nodes) ProtoMessage 

func (*Nodes) ProtoMessage()

func (*Nodes) Reset 

func (m *Nodes) Reset()

func (*Nodes) String 

func (m *Nodes) String() string

func (*Nodes) XXX_DiscardUnknown 

func (m *Nodes) XXX_DiscardUnknown()

func (*Nodes) XXX_Marshal 

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

func (*Nodes) XXX_Merge 

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

func (*Nodes) XXX_Size 

func (m *Nodes) XXX_Size() int

func (*Nodes) XXX_Unmarshal 

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

type ProcessNodeResponse 

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

func (*ProcessNodeResponse) Descriptor 

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

func (*ProcessNodeResponse) ProtoMessage 

func (*ProcessNodeResponse) ProtoMessage()

func (*ProcessNodeResponse) Reset 

func (m *ProcessNodeResponse) Reset()

func (*ProcessNodeResponse) String 

func (m *ProcessNodeResponse) String() string

func (*ProcessNodeResponse) XXX_DiscardUnknown 

func (m *ProcessNodeResponse) XXX_DiscardUnknown()

func (*ProcessNodeResponse) XXX_Marshal 

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

func (*ProcessNodeResponse) XXX_Merge 

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

func (*ProcessNodeResponse) XXX_Size 

func (m *ProcessNodeResponse) XXX_Size() int

func (*ProcessNodeResponse) XXX_Unmarshal 

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

type Query 

type Query struct {
	FilterMap            []*common.Filter `protobuf:"bytes,25,rep,name=filter_map,json=filterMap,proto3" json:"filter_map,omitempty"`
	Order                Query_OrderType  `` /* 131-byte string literal not displayed */
	Sort                 string           `protobuf:"bytes,22,opt,name=sort,proto3" json:"sort,omitempty"`
	Page                 int32            `protobuf:"varint,23,opt,name=page,proto3" json:"page,omitempty"`
	PerPage              int32            `protobuf:"varint,24,opt,name=per_page,json=perPage,proto3" json:"per_page,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*Query) Descriptor 

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

func (*Query) GetFilterMap 

func (m *Query) GetFilterMap() []*common.Filter

func (*Query) GetOrder 

func (m *Query) GetOrder() Query_OrderType

func (*Query) GetPage 

func (m *Query) GetPage() int32

func (*Query) GetPerPage 

func (m *Query) GetPerPage() int32

func (*Query) GetSort 

func (m *Query) GetSort() string

func (*Query) ProtoMessage 

func (*Query) ProtoMessage()

func (*Query) Reset 

func (m *Query) Reset()

func (*Query) String 

func (m *Query) String() string

func (*Query) XXX_DiscardUnknown 

func (m *Query) XXX_DiscardUnknown()

func (*Query) XXX_Marshal 

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

func (*Query) XXX_Merge 

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

func (*Query) XXX_Size 

func (m *Query) XXX_Size() int

func (*Query) XXX_Unmarshal 

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

type Query_OrderType 

type Query_OrderType int32
const (
	Query_ASC  Query_OrderType = 0
	Query_DESC Query_OrderType = 1
)

func (Query_OrderType) EnumDescriptor 

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

func (Query_OrderType) String 

func (x Query_OrderType) String() string

Source Files

View all Source files

Directories

Path Synopsis

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.