manager

package
v0.0.0-...-d73d392 Latest Latest
Warning

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

Go to latest
Published: May 3, 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

ChangeNodeState mocks base method

func (*MockNodeManagerServiceClient) Connect

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

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

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

List mocks base method

func (*MockNodeManagerServiceClient) ProcessNode

ProcessNode mocks base method

func (*MockNodeManagerServiceClient) Read

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

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

ChangeNodeState mocks base method

func (*MockNodeManagerServiceServer) Connect

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

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

List mocks base method

func (*MockNodeManagerServiceServer) ProcessNode

ProcessNode mocks base method

func (*MockNodeManagerServiceServer) Read

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

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.

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) 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 (NodeState_State) String

func (x NodeState_State) String() string

func (NodeState_State) Type

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) 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 (Query_OrderType) String

func (x Query_OrderType) String() string

func (Query_OrderType) Type

type UnimplementedNodeManagerServiceServer

type UnimplementedNodeManagerServiceServer struct {
}

UnimplementedNodeManagerServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedNodeManagerServiceServer) ChangeNodeState

func (*UnimplementedNodeManagerServiceServer) Connect

func (*UnimplementedNodeManagerServiceServer) ConnectManager

func (*UnimplementedNodeManagerServiceServer) Create

func (*UnimplementedNodeManagerServiceServer) Delete

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) GetNodeWithSecrets

func (*UnimplementedNodeManagerServiceServer) List

func (*UnimplementedNodeManagerServiceServer) ProcessNode

func (*UnimplementedNodeManagerServiceServer) Read

func (*UnimplementedNodeManagerServiceServer) SearchManagerNodes

func (*UnimplementedNodeManagerServiceServer) SearchNodeFields

func (*UnimplementedNodeManagerServiceServer) SearchNodes

func (*UnimplementedNodeManagerServiceServer) Update

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL