manager

package
v0.0.0-...-5a7b0e6 Latest Latest
Warning

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

 Go to latest Published: Dec 27, 2024 License: Apache-2.0 Imports: 14 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",
		3: "MISSING",
	}
	NodeState_State_value = map[string]int32{
		"RUNNING":    0,
		"STOPPED":    1,
		"TERMINATED": 2,
		"MISSING":    3,
	}
)

Enum value maps for NodeState_State.

View Source 
var (
	Query_OrderType_name = map[int32]string{
		0: "ASC",
		1: "DESC",
	}
	Query_OrderType_value = map[string]int32{
		"ASC":  0,
		"DESC": 1,
	}
)

Enum value maps for Query_OrderType.

View Source 
var File_interservice_nodemanager_manager_manager_proto protoreflect.FileDescriptor

Functions

func RegisterNodeManagerServiceServer 

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

Types

type ChangeNodeStateResponse 

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

func (*ChangeNodeStateResponse) Descriptor deprecated 

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

Deprecated: Use ChangeNodeStateResponse.ProtoReflect.Descriptor instead.

func (*ChangeNodeStateResponse) ProtoMessage 

func (*ChangeNodeStateResponse) ProtoMessage()

func (*ChangeNodeStateResponse) ProtoReflect 

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

func (*ChangeNodeStateResponse) Reset 

func (x *ChangeNodeStateResponse) Reset()

func (*ChangeNodeStateResponse) String 

func (x *ChangeNodeStateResponse) String() string

type Credentials 

type Credentials struct {
	Credentials string `` /* 142-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Credentials) Descriptor deprecated 

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

Deprecated: Use Credentials.ProtoReflect.Descriptor instead.

func (*Credentials) GetCredentials 

func (x *Credentials) GetCredentials() string

func (*Credentials) ProtoMessage 

func (*Credentials) ProtoMessage()

func (*Credentials) ProtoReflect 

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

func (*Credentials) Reset 

func (x *Credentials) Reset()

func (*Credentials) String 

func (x *Credentials) String() string

type CredentialsByTags 

type CredentialsByTags struct {
	TagKey        string   `` /* 138-byte string literal not displayed */
	TagValue      string   `` /* 148-byte string literal not displayed */
	CredentialIds []string `` /* 173-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CredentialsByTags) Descriptor deprecated 

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

Deprecated: Use CredentialsByTags.ProtoReflect.Descriptor instead.

func (*CredentialsByTags) GetCredentialIds 

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

func (*CredentialsByTags) GetTagKey 

func (x *CredentialsByTags) GetTagKey() string

func (*CredentialsByTags) GetTagValue 

func (x *CredentialsByTags) GetTagValue() string

func (*CredentialsByTags) ProtoMessage 

func (*CredentialsByTags) ProtoMessage()

func (*CredentialsByTags) ProtoReflect 

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

func (*CredentialsByTags) Reset 

func (x *CredentialsByTags) Reset()

func (*CredentialsByTags) String 

func (x *CredentialsByTags) String() string

type FieldQuery 

type FieldQuery struct {
	Query         *Query `protobuf:"bytes,20,opt,name=query,proto3" json:"query,omitempty" toml:"query,omitempty" mapstructure:"query,omitempty"`
	Field         string `protobuf:"bytes,21,opt,name=field,proto3" json:"field,omitempty" toml:"field,omitempty" mapstructure:"field,omitempty"`
	NodeManagerId string `` /* 177-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*FieldQuery) Descriptor deprecated 

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

Deprecated: Use FieldQuery.ProtoReflect.Descriptor instead.

func (*FieldQuery) GetField 

func (x *FieldQuery) GetField() string

func (*FieldQuery) GetNodeManagerId 

func (x *FieldQuery) GetNodeManagerId() string

func (*FieldQuery) GetQuery 

func (x *FieldQuery) GetQuery() *Query

func (*FieldQuery) ProtoMessage 

func (*FieldQuery) ProtoMessage()

func (*FieldQuery) ProtoReflect 

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

func (*FieldQuery) Reset 

func (x *FieldQuery) Reset()

func (*FieldQuery) String 

func (x *FieldQuery) String() string

type Fields 

type Fields struct {
	Fields []string `protobuf:"bytes,1,rep,name=fields,proto3" json:"fields,omitempty" toml:"fields,omitempty" mapstructure:"fields,omitempty"`
	// contains filtered or unexported fields
}

func (*Fields) Descriptor deprecated 

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

Deprecated: Use Fields.ProtoReflect.Descriptor instead.

func (*Fields) GetFields 

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

func (*Fields) ProtoMessage 

func (*Fields) ProtoMessage()

func (*Fields) ProtoReflect 

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

func (*Fields) Reset 

func (x *Fields) Reset()

func (*Fields) String 

func (x *Fields) String() string

type Id 

type Id struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty" toml:"id,omitempty" mapstructure:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*Id) Descriptor deprecated 

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

Deprecated: Use Id.ProtoReflect.Descriptor instead.

func (*Id) GetId 

func (x *Id) GetId() string

func (*Id) ProtoMessage 

func (*Id) ProtoMessage()

func (*Id) ProtoReflect 

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

func (*Id) Reset 

func (x *Id) Reset()

func (*Id) String 

func (x *Id) String() string

type Ids 

type Ids struct {
	Ids []*Id `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty" toml:"ids,omitempty" mapstructure:"ids,omitempty"`
	// contains filtered or unexported fields
}

func (*Ids) Descriptor deprecated 

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

Deprecated: Use Ids.ProtoReflect.Descriptor instead.

func (*Ids) GetIds 

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

func (*Ids) ProtoMessage 

func (*Ids) ProtoMessage()

func (*Ids) ProtoReflect 

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

func (*Ids) Reset 

func (x *Ids) Reset()

func (*Ids) String 

func (x *Ids) String() string

type ManagerNode 

type ManagerNode struct {
	Id       string       `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty" toml:"id,omitempty" mapstructure:"id,omitempty"`
	Host     string       `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty" toml:"host,omitempty" mapstructure:"host,omitempty"`
	PublicIp string       `` /* 147-byte string literal not displayed */
	Tags     []*common.Kv `protobuf:"bytes,4,rep,name=tags,proto3" json:"tags,omitempty" toml:"tags,omitempty" mapstructure:"tags,omitempty"`
	Platform string       `` /* 129-byte string literal not displayed */
	// should all these be tags??
	Region            string `protobuf:"bytes,6,opt,name=region,proto3" json:"region,omitempty" toml:"region,omitempty" mapstructure:"region,omitempty"`
	Name              string `protobuf:"bytes,7,opt,name=name,proto3" json:"name,omitempty" toml:"name,omitempty" mapstructure:"name,omitempty"`
	Ssm               string `protobuf:"bytes,8,opt,name=ssm,proto3" json:"ssm,omitempty" toml:"ssm,omitempty" mapstructure:"ssm,omitempty"`
	Uuid              string `protobuf:"bytes,9,opt,name=uuid,proto3" json:"uuid,omitempty" toml:"uuid,omitempty" mapstructure:"uuid,omitempty"`
	MachineIdentifier string `` /* 193-byte string literal not displayed */
	Group             string `protobuf:"bytes,11,opt,name=group,proto3" json:"group,omitempty" toml:"group,omitempty" mapstructure:"group,omitempty"`
	// contains filtered or unexported fields
}

func (*ManagerNode) Descriptor deprecated 

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

Deprecated: Use ManagerNode.ProtoReflect.Descriptor instead.

func (*ManagerNode) GetGroup 

func (x *ManagerNode) GetGroup() string

func (*ManagerNode) GetHost 

func (x *ManagerNode) GetHost() string

func (*ManagerNode) GetId 

func (x *ManagerNode) GetId() string

func (*ManagerNode) GetMachineIdentifier 

func (x *ManagerNode) GetMachineIdentifier() string

func (*ManagerNode) GetName 

func (x *ManagerNode) GetName() string

func (*ManagerNode) GetPlatform 

func (x *ManagerNode) GetPlatform() string

func (*ManagerNode) GetPublicIp 

func (x *ManagerNode) GetPublicIp() string

func (*ManagerNode) GetRegion 

func (x *ManagerNode) GetRegion() string

func (*ManagerNode) GetSsm 

func (x *ManagerNode) GetSsm() string

func (*ManagerNode) GetTags 

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

func (*ManagerNode) GetUuid 

func (x *ManagerNode) GetUuid() string

func (*ManagerNode) ProtoMessage 

func (*ManagerNode) ProtoMessage()

func (*ManagerNode) ProtoReflect 

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

func (*ManagerNode) Reset 

func (x *ManagerNode) Reset()

func (*ManagerNode) String 

func (x *ManagerNode) String() string

type ManagerNodes 

type ManagerNodes struct {
	Nodes []*ManagerNode `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty" toml:"nodes,omitempty" mapstructure:"nodes,omitempty"`
	// contains filtered or unexported fields
}

func (*ManagerNodes) Descriptor deprecated 

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

Deprecated: Use ManagerNodes.ProtoReflect.Descriptor instead.

func (*ManagerNodes) GetNodes 

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

func (*ManagerNodes) ProtoMessage 

func (*ManagerNodes) ProtoMessage()

func (*ManagerNodes) ProtoReflect 

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

func (*ManagerNodes) Reset 

func (x *ManagerNodes) Reset()

func (*ManagerNodes) String 

func (x *ManagerNodes) String() string

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) (*emptypb.Empty, error)

Connect mocks base method.

func (*MockNodeManagerServiceClient) ConnectManager 

func (m *MockNodeManagerServiceClient) ConnectManager(ctx context.Context, in *Id, opts ...grpc.CallOption) (*emptypb.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) (*emptypb.Empty, error)

Delete mocks base method.

func (*MockNodeManagerServiceClient) DeleteWithNodeStateStopped 

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

DeleteWithNodeStateStopped mocks base method.

func (*MockNodeManagerServiceClient) DeleteWithNodeStateTerminated 

func (m *MockNodeManagerServiceClient) DeleteWithNodeStateTerminated(ctx context.Context, in *Id, opts ...grpc.CallOption) (*emptypb.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) (*emptypb.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) (*emptypb.Empty, error)

Connect mocks base method.

func (*MockNodeManagerServiceServer) ConnectManager 

func (m *MockNodeManagerServiceServer) ConnectManager(arg0 context.Context, arg1 *Id) (*emptypb.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) (*emptypb.Empty, error)

Delete mocks base method.

func (*MockNodeManagerServiceServer) DeleteWithNodeStateStopped 

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

DeleteWithNodeStateStopped mocks base method.

func (*MockNodeManagerServiceServer) DeleteWithNodeStateTerminated 

func (m *MockNodeManagerServiceServer) DeleteWithNodeStateTerminated(arg0 context.Context, arg1 *Id) (*emptypb.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) (*emptypb.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" toml:"id,omitempty" mapstructure:"id,omitempty"`
	Name         string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty" toml:"name,omitempty" mapstructure:"name,omitempty"`
	Type         string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty" toml:"type,omitempty" mapstructure:"type,omitempty"`
	CredentialId string `` // aws or azure cred id
	/* 168-byte string literal not displayed */
	InstanceCredentials []*CredentialsByTags `` // ssh, winrm creds
	/* 203-byte string literal not displayed */
	Status         string                 `protobuf:"bytes,22,opt,name=status,proto3" json:"status,omitempty" toml:"status,omitempty" mapstructure:"status,omitempty"`
	AccountId      string                 `` /* 153-byte string literal not displayed */
	DateAdded      *timestamppb.Timestamp `` /* 153-byte string literal not displayed */
	CredentialData []*common.Kv           `` /* 178-byte string literal not displayed */
	AccountAlias   string                 `` /* 168-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*NodeManager) Descriptor deprecated 

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

Deprecated: Use NodeManager.ProtoReflect.Descriptor instead.

func (*NodeManager) GetAccountAlias 

func (x *NodeManager) GetAccountAlias() string

func (*NodeManager) GetAccountId 

func (x *NodeManager) GetAccountId() string

func (*NodeManager) GetCredentialData 

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

func (*NodeManager) GetCredentialId 

func (x *NodeManager) GetCredentialId() string

func (*NodeManager) GetDateAdded 

func (x *NodeManager) GetDateAdded() *timestamppb.Timestamp

func (*NodeManager) GetId 

func (x *NodeManager) GetId() string

func (*NodeManager) GetInstanceCredentials 

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

func (*NodeManager) GetName 

func (x *NodeManager) GetName() string

func (*NodeManager) GetStatus 

func (x *NodeManager) GetStatus() string

func (*NodeManager) GetType 

func (x *NodeManager) GetType() string

func (*NodeManager) ProtoMessage 

func (*NodeManager) ProtoMessage()

func (*NodeManager) ProtoReflect 

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

func (*NodeManager) Reset 

func (x *NodeManager) Reset()

func (*NodeManager) String 

func (x *NodeManager) String() string

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) (*emptypb.Empty, error)
	Delete(ctx context.Context, in *Id, opts ...grpc.CallOption) (*emptypb.Empty, error)
	DeleteWithNodes(ctx context.Context, in *Id, opts ...grpc.CallOption) (*Ids, error)
	DeleteWithNodeStateStopped(ctx context.Context, in *Id, opts ...grpc.CallOption) (*emptypb.Empty, error)
	DeleteWithNodeStateTerminated(ctx context.Context, in *Id, opts ...grpc.CallOption) (*emptypb.Empty, error)
	List(ctx context.Context, in *Query, opts ...grpc.CallOption) (*NodeManagers, error)
	Connect(ctx context.Context, in *NodeManager, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ConnectManager(ctx context.Context, in *Id, opts ...grpc.CallOption) (*emptypb.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.ClientConnInterface) NodeManagerServiceClient

type NodeManagerServiceServer 

type NodeManagerServiceServer interface {
	Create(context.Context, *NodeManager) (*Ids, error)
	Read(context.Context, *Id) (*NodeManager, error)
	Update(context.Context, *NodeManager) (*emptypb.Empty, error)
	Delete(context.Context, *Id) (*emptypb.Empty, error)
	DeleteWithNodes(context.Context, *Id) (*Ids, error)
	DeleteWithNodeStateStopped(context.Context, *Id) (*emptypb.Empty, error)
	DeleteWithNodeStateTerminated(context.Context, *Id) (*emptypb.Empty, error)
	List(context.Context, *Query) (*NodeManagers, error)
	Connect(context.Context, *NodeManager) (*emptypb.Empty, error)
	ConnectManager(context.Context, *Id) (*emptypb.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 `` /* 129-byte string literal not displayed */
	Total    int32          `protobuf:"varint,20,opt,name=total,proto3" json:"total,omitempty" toml:"total,omitempty" mapstructure:"total,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeManagers) Descriptor deprecated 

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

Deprecated: Use NodeManagers.ProtoReflect.Descriptor instead.

func (*NodeManagers) GetManagers 

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

func (*NodeManagers) GetTotal 

func (x *NodeManagers) GetTotal() int32

func (*NodeManagers) ProtoMessage 

func (*NodeManagers) ProtoMessage()

func (*NodeManagers) ProtoReflect 

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

func (*NodeManagers) Reset 

func (x *NodeManagers) Reset()

func (*NodeManagers) String 

func (x *NodeManagers) String() string

type NodeMetadata 

type NodeMetadata struct {
	Uuid            string                 `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty" toml:"uuid,omitempty" mapstructure:"uuid,omitempty"`
	Name            string                 `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty" toml:"name,omitempty" mapstructure:"name,omitempty"`
	PlatformName    string                 `` /* 167-byte string literal not displayed */
	PlatformRelease string                 `` /* 182-byte string literal not displayed */
	JobUuid         string                 `` /* 142-byte string literal not displayed */
	LastContact     *timestamppb.Timestamp `` /* 162-byte string literal not displayed */
	SourceId        string                 `` /* 147-byte string literal not displayed */
	SourceRegion    string                 `` /* 167-byte string literal not displayed */
	SourceAccountId string                 `` /* 186-byte string literal not displayed */
	Tags            []*common.Kv           `protobuf:"bytes,10,rep,name=tags,proto3" json:"tags,omitempty" toml:"tags,omitempty" mapstructure:"tags,omitempty"`
	RunData         *nodes.LastContactData `` /* 143-byte string literal not displayed */
	ScanData        *nodes.LastContactData `` /* 148-byte string literal not displayed */
	ProjectsData    []*nodes.ProjectsData  `` /* 168-byte string literal not displayed */
	Projects        []string               `` /* 130-byte string literal not displayed */
	ManagerId       string                 `` /* 153-byte string literal not displayed */
	ManagerType     string                 `` /* 163-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*NodeMetadata) Descriptor deprecated 

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

Deprecated: Use NodeMetadata.ProtoReflect.Descriptor instead.

func (*NodeMetadata) GetJobUuid 

func (x *NodeMetadata) GetJobUuid() string

func (*NodeMetadata) GetLastContact 

func (x *NodeMetadata) GetLastContact() *timestamppb.Timestamp

func (*NodeMetadata) GetManagerId 

func (x *NodeMetadata) GetManagerId() string

func (*NodeMetadata) GetManagerType 

func (x *NodeMetadata) GetManagerType() string

func (*NodeMetadata) GetName 

func (x *NodeMetadata) GetName() string

func (*NodeMetadata) GetPlatformName 

func (x *NodeMetadata) GetPlatformName() string

func (*NodeMetadata) GetPlatformRelease 

func (x *NodeMetadata) GetPlatformRelease() string

func (*NodeMetadata) GetProjects 

func (x *NodeMetadata) GetProjects() []string

func (*NodeMetadata) GetProjectsData 

func (x *NodeMetadata) GetProjectsData() []*nodes.ProjectsData

func (*NodeMetadata) GetRunData 

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

func (*NodeMetadata) GetScanData 

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

func (*NodeMetadata) GetSourceAccountId 

func (x *NodeMetadata) GetSourceAccountId() string

func (*NodeMetadata) GetSourceId 

func (x *NodeMetadata) GetSourceId() string

func (*NodeMetadata) GetSourceRegion 

func (x *NodeMetadata) GetSourceRegion() string

func (*NodeMetadata) GetTags 

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

func (*NodeMetadata) GetUuid 

func (x *NodeMetadata) GetUuid() string

func (*NodeMetadata) ProtoMessage 

func (*NodeMetadata) ProtoMessage()

func (*NodeMetadata) ProtoReflect 

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

func (*NodeMetadata) Reset 

func (x *NodeMetadata) Reset()

func (*NodeMetadata) String 

func (x *NodeMetadata) String() string

type NodeQuery 

type NodeQuery struct {
	Query         *Query `protobuf:"bytes,20,opt,name=query,proto3" json:"query,omitempty" toml:"query,omitempty" mapstructure:"query,omitempty"`
	NodeManagerId string `` /* 177-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*NodeQuery) Descriptor deprecated 

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

Deprecated: Use NodeQuery.ProtoReflect.Descriptor instead.

func (*NodeQuery) GetNodeManagerId 

func (x *NodeQuery) GetNodeManagerId() string

func (*NodeQuery) GetQuery 

func (x *NodeQuery) GetQuery() *Query

func (*NodeQuery) ProtoMessage 

func (*NodeQuery) ProtoMessage()

func (*NodeQuery) ProtoReflect 

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

func (*NodeQuery) Reset 

func (x *NodeQuery) Reset()

func (*NodeQuery) String 

func (x *NodeQuery) String() string

type NodeState 

type NodeState struct {
	Id    string          `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty" toml:"id,omitempty" mapstructure:"id,omitempty"`
	State NodeState_State `` /* 180-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*NodeState) Descriptor deprecated 

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

Deprecated: Use NodeState.ProtoReflect.Descriptor instead.

func (*NodeState) GetId 

func (x *NodeState) GetId() string

func (*NodeState) GetState 

func (x *NodeState) GetState() NodeState_State

func (*NodeState) ProtoMessage 

func (*NodeState) ProtoMessage()

func (*NodeState) ProtoReflect 

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

func (*NodeState) Reset 

func (x *NodeState) Reset()

func (*NodeState) String 

func (x *NodeState) String() string

type NodeState_State 

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

func (NodeState_State) Descriptor 

func (NodeState_State) Descriptor() protoreflect.EnumDescriptor

func (NodeState_State) Enum 

func (x NodeState_State) Enum() *NodeState_State

func (NodeState_State) EnumDescriptor deprecated 

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

Deprecated: Use NodeState_State.Descriptor instead.

func (NodeState_State) Number 

func (x NodeState_State) Number() protoreflect.EnumNumber

func (NodeState_State) String 

func (x NodeState_State) String() string

func (NodeState_State) Type 

func (NodeState_State) Type() protoreflect.EnumType

type Nodes 

type Nodes struct {
	Nodes []string `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty" toml:"nodes,omitempty" mapstructure:"nodes,omitempty"`
	Total int32    `protobuf:"varint,20,opt,name=total,proto3" json:"total,omitempty" toml:"total,omitempty" mapstructure:"total,omitempty"`
	// contains filtered or unexported fields
}

func (*Nodes) Descriptor deprecated 

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

Deprecated: Use Nodes.ProtoReflect.Descriptor instead.

func (*Nodes) GetNodes 

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

func (*Nodes) GetTotal 

func (x *Nodes) GetTotal() int32

func (*Nodes) ProtoMessage 

func (*Nodes) ProtoMessage()

func (*Nodes) ProtoReflect 

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

func (*Nodes) Reset 

func (x *Nodes) Reset()

func (*Nodes) String 

func (x *Nodes) String() string

type ProcessNodeResponse 

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

func (*ProcessNodeResponse) Descriptor deprecated 

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

Deprecated: Use ProcessNodeResponse.ProtoReflect.Descriptor instead.

func (*ProcessNodeResponse) ProtoMessage 

func (*ProcessNodeResponse) ProtoMessage()

func (*ProcessNodeResponse) ProtoReflect 

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

func (*ProcessNodeResponse) Reset 

func (x *ProcessNodeResponse) Reset()

func (*ProcessNodeResponse) String 

func (x *ProcessNodeResponse) String() string

type Query 

type Query struct {
	FilterMap []*common.Filter `` /* 153-byte string literal not displayed */
	Order     Query_OrderType  `` /* 181-byte string literal not displayed */
	Sort      string           `protobuf:"bytes,22,opt,name=sort,proto3" json:"sort,omitempty" toml:"sort,omitempty" mapstructure:"sort,omitempty"`
	Page      int32            `protobuf:"varint,23,opt,name=page,proto3" json:"page,omitempty" toml:"page,omitempty" mapstructure:"page,omitempty"`
	PerPage   int32            `` /* 144-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Query) Descriptor deprecated 

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

Deprecated: Use Query.ProtoReflect.Descriptor instead.

func (*Query) GetFilterMap 

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

func (*Query) GetOrder 

func (x *Query) GetOrder() Query_OrderType

func (*Query) GetPage 

func (x *Query) GetPage() int32

func (*Query) GetPerPage 

func (x *Query) GetPerPage() int32

func (*Query) GetSort 

func (x *Query) GetSort() string

func (*Query) ProtoMessage 

func (*Query) ProtoMessage()

func (*Query) ProtoReflect 

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

func (*Query) Reset 

func (x *Query) Reset()

func (*Query) String 

func (x *Query) String() string

type Query_OrderType 

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

func (Query_OrderType) Descriptor 

func (Query_OrderType) Descriptor() protoreflect.EnumDescriptor

func (Query_OrderType) Enum 

func (x Query_OrderType) Enum() *Query_OrderType

func (Query_OrderType) EnumDescriptor deprecated 

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

Deprecated: Use Query_OrderType.Descriptor instead.

func (Query_OrderType) Number 

func (x Query_OrderType) Number() protoreflect.EnumNumber

func (Query_OrderType) String 

func (x Query_OrderType) String() string

func (Query_OrderType) Type 

func (Query_OrderType) Type() protoreflect.EnumType

type UnimplementedNodeManagerServiceServer 

type UnimplementedNodeManagerServiceServer struct {
}

UnimplementedNodeManagerServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedNodeManagerServiceServer) ChangeNodeState 

func (*UnimplementedNodeManagerServiceServer) ChangeNodeState(context.Context, *NodeState) (*ChangeNodeStateResponse, error)

func (*UnimplementedNodeManagerServiceServer) Connect 

func (*UnimplementedNodeManagerServiceServer) Connect(context.Context, *NodeManager) (*emptypb.Empty, error)

func (*UnimplementedNodeManagerServiceServer) ConnectManager 

func (*UnimplementedNodeManagerServiceServer) ConnectManager(context.Context, *Id) (*emptypb.Empty, error)

func (*UnimplementedNodeManagerServiceServer) Create 

func (*UnimplementedNodeManagerServiceServer) Create(context.Context, *NodeManager) (*Ids, error)

func (*UnimplementedNodeManagerServiceServer) Delete 

func (*UnimplementedNodeManagerServiceServer) Delete(context.Context, *Id) (*emptypb.Empty, error)

func (*UnimplementedNodeManagerServiceServer) DeleteWithNodeStateStopped 

func (*UnimplementedNodeManagerServiceServer) DeleteWithNodeStateStopped(context.Context, *Id) (*emptypb.Empty, error)

func (*UnimplementedNodeManagerServiceServer) DeleteWithNodeStateTerminated 

func (*UnimplementedNodeManagerServiceServer) DeleteWithNodeStateTerminated(context.Context, *Id) (*emptypb.Empty, error)

func (*UnimplementedNodeManagerServiceServer) DeleteWithNodes 

func (*UnimplementedNodeManagerServiceServer) DeleteWithNodes(context.Context, *Id) (*Ids, error)

func (*UnimplementedNodeManagerServiceServer) GetNodeWithSecrets 

func (*UnimplementedNodeManagerServiceServer) GetNodeWithSecrets(context.Context, *Id) (*nodes.Node, error)

func (*UnimplementedNodeManagerServiceServer) List 

func (*UnimplementedNodeManagerServiceServer) List(context.Context, *Query) (*NodeManagers, error)

func (*UnimplementedNodeManagerServiceServer) ProcessNode 

func (*UnimplementedNodeManagerServiceServer) ProcessNode(context.Context, *NodeMetadata) (*ProcessNodeResponse, error)

func (*UnimplementedNodeManagerServiceServer) Read 

func (*UnimplementedNodeManagerServiceServer) Read(context.Context, *Id) (*NodeManager, error)

func (*UnimplementedNodeManagerServiceServer) SearchManagerNodes 

func (*UnimplementedNodeManagerServiceServer) SearchManagerNodes(context.Context, *NodeQuery) (*ManagerNodes, error)

func (*UnimplementedNodeManagerServiceServer) SearchNodeFields 

func (*UnimplementedNodeManagerServiceServer) SearchNodeFields(context.Context, *FieldQuery) (*Fields, error)

func (*UnimplementedNodeManagerServiceServer) SearchNodes 

func (*UnimplementedNodeManagerServiceServer) SearchNodes(context.Context, *NodeQuery) (*Nodes, error)

func (*UnimplementedNodeManagerServiceServer) Update 

func (*UnimplementedNodeManagerServiceServer) Update(context.Context, *NodeManager) (*emptypb.Empty, 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.