nodes

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: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var LastContactData_Status_name = map[int32]string{
	0: "UNKNOWN",
	1: "PASSED",
	2: "FAILED",
	3: "SKIPPED",
}
View Source 
var LastContactData_Status_value = map[string]int32{
	"UNKNOWN": 0,
	"PASSED":  1,
	"FAILED":  2,
	"SKIPPED": 3,
}
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 PrepareSSHPrivateKey 

func PrepareSSHPrivateKey(keyContent string) (string, error)

PrepareSSHPrivateKey takes the contents of a SSH key and saves them into a temporary file

func RegisterNodesServiceServer 

func RegisterNodesServiceServer(s *grpc.Server, srv NodesServiceServer)

Types

type BulkDeleteResponse 

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

func (*BulkDeleteResponse) Descriptor 

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

func (*BulkDeleteResponse) GetNames 

func (m *BulkDeleteResponse) GetNames() []string

func (*BulkDeleteResponse) ProtoMessage 

func (*BulkDeleteResponse) ProtoMessage()

func (*BulkDeleteResponse) Reset 

func (m *BulkDeleteResponse) Reset()

func (*BulkDeleteResponse) String 

func (m *BulkDeleteResponse) String() string

func (*BulkDeleteResponse) XXX_DiscardUnknown 

func (m *BulkDeleteResponse) XXX_DiscardUnknown()

func (*BulkDeleteResponse) XXX_Marshal 

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

func (*BulkDeleteResponse) XXX_Merge 

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

func (*BulkDeleteResponse) XXX_Size 

func (m *BulkDeleteResponse) XXX_Size() int

func (*BulkDeleteResponse) XXX_Unmarshal 

func (m *BulkDeleteResponse) 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                  []string `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() []string

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 LastContactData 

type LastContactData struct {
	Id                   string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Status               LastContactData_Status `` /* 137-byte string literal not displayed */
	PenultimateStatus    LastContactData_Status `` /* 184-byte string literal not displayed */
	EndTime              *timestamp.Timestamp   `protobuf:"bytes,4,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*LastContactData) Descriptor 

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

func (*LastContactData) GetEndTime 

func (m *LastContactData) GetEndTime() *timestamp.Timestamp

func (*LastContactData) GetId 

func (m *LastContactData) GetId() string

func (*LastContactData) GetPenultimateStatus 

func (m *LastContactData) GetPenultimateStatus() LastContactData_Status

func (*LastContactData) GetStatus 

func (m *LastContactData) GetStatus() LastContactData_Status

func (*LastContactData) ProtoMessage 

func (*LastContactData) ProtoMessage()

func (*LastContactData) Reset 

func (m *LastContactData) Reset()

func (*LastContactData) String 

func (m *LastContactData) String() string

func (*LastContactData) XXX_DiscardUnknown 

func (m *LastContactData) XXX_DiscardUnknown()

func (*LastContactData) XXX_Marshal 

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

func (*LastContactData) XXX_Merge 

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

func (*LastContactData) XXX_Size 

func (m *LastContactData) XXX_Size() int

func (*LastContactData) XXX_Unmarshal 

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

type LastContactData_Status 

type LastContactData_Status int32
const (
	LastContactData_UNKNOWN LastContactData_Status = 0
	LastContactData_PASSED  LastContactData_Status = 1
	LastContactData_FAILED  LastContactData_Status = 2
	LastContactData_SKIPPED LastContactData_Status = 3
)

func (LastContactData_Status) EnumDescriptor 

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

func (LastContactData_Status) String 

func (x LastContactData_Status) String() string

type Node 

type Node 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"`
	Platform             string               `protobuf:"bytes,3,opt,name=platform,proto3" json:"platform,omitempty"`
	PlatformVersion      string               `protobuf:"bytes,4,opt,name=platform_version,json=platformVersion,proto3" json:"platform_version,omitempty"`
	Manager              string               `protobuf:"bytes,5,opt,name=manager,proto3" json:"manager,omitempty"`
	Tags                 []*common.Kv         `protobuf:"bytes,20,rep,name=tags,proto3" json:"tags,omitempty"`
	LastContact          *timestamp.Timestamp `protobuf:"bytes,21,opt,name=last_contact,json=lastContact,proto3" json:"last_contact,omitempty"`
	Status               string               `protobuf:"bytes,22,opt,name=status,proto3" json:"status,omitempty"`
	LastJob              *ResultsRow          `protobuf:"bytes,23,opt,name=last_job,json=lastJob,proto3" json:"last_job,omitempty"`
	TargetConfig         *TargetConfig        `protobuf:"bytes,99,opt,name=target_config,json=targetConfig,proto3" json:"target_config,omitempty"`
	ManagerIds           []string             `protobuf:"bytes,24,rep,name=manager_ids,json=managerIds,proto3" json:"manager_ids,omitempty"`
	ConnectionError      string               `protobuf:"bytes,25,opt,name=connection_error,json=connectionError,proto3" json:"connection_error,omitempty"`
	State                string               `protobuf:"bytes,26,opt,name=state,proto3" json:"state,omitempty"`
	NamePrefix           string               `protobuf:"bytes,27,opt,name=name_prefix,json=namePrefix,proto3" json:"name_prefix,omitempty"`
	Projects             []string             `protobuf:"bytes,28,rep,name=projects,proto3" json:"projects,omitempty"`
	RunData              *LastContactData     `protobuf:"bytes,29,opt,name=run_data,json=runData,proto3" json:"run_data,omitempty"`
	ScanData             *LastContactData     `protobuf:"bytes,30,opt,name=scan_data,json=scanData,proto3" json:"scan_data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*Node) Descriptor 

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

func (*Node) GetConnectionError 

func (m *Node) GetConnectionError() string

func (*Node) GetId 

func (m *Node) GetId() string

func (*Node) GetLastContact 

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

func (*Node) GetLastJob 

func (m *Node) GetLastJob() *ResultsRow

func (*Node) GetManager 

func (m *Node) GetManager() string

func (*Node) GetManagerIds 

func (m *Node) GetManagerIds() []string

func (*Node) GetName 

func (m *Node) GetName() string

func (*Node) GetNamePrefix 

func (m *Node) GetNamePrefix() string

func (*Node) GetPlatform 

func (m *Node) GetPlatform() string

func (*Node) GetPlatformVersion 

func (m *Node) GetPlatformVersion() string

func (*Node) GetProjects 

func (m *Node) GetProjects() []string

func (*Node) GetRunData 

func (m *Node) GetRunData() *LastContactData

func (*Node) GetScanData 

func (m *Node) GetScanData() *LastContactData

func (*Node) GetState 

func (m *Node) GetState() string

func (*Node) GetStatus 

func (m *Node) GetStatus() string

func (*Node) GetTags 

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

func (*Node) GetTargetConfig 

func (m *Node) GetTargetConfig() *TargetConfig

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) Reset 

func (m *Node) Reset()

func (*Node) String 

func (m *Node) String() string

func (*Node) XXX_DiscardUnknown 

func (m *Node) XXX_DiscardUnknown()

func (*Node) XXX_Marshal 

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

func (*Node) XXX_Merge 

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

func (*Node) XXX_Size 

func (m *Node) XXX_Size() int

func (*Node) XXX_Unmarshal 

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

type NodeDetectJobInfo 

type NodeDetectJobInfo struct {
	NodeId               string               `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	PlatformName         string               `protobuf:"bytes,2,opt,name=platform_name,json=platformName,proto3" json:"platform_name,omitempty"`
	PlatformRelease      string               `protobuf:"bytes,3,opt,name=platform_release,json=platformRelease,proto3" json:"platform_release,omitempty"`
	NodeStatus           string               `protobuf:"bytes,4,opt,name=node_status,json=nodeStatus,proto3" json:"node_status,omitempty"`
	JobEndTime           *timestamp.Timestamp `protobuf:"bytes,5,opt,name=job_end_time,json=jobEndTime,proto3" json:"job_end_time,omitempty"`
	JobId                string               `protobuf:"bytes,6,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	NodeState            string               `protobuf:"bytes,7,opt,name=node_state,json=nodeState,proto3" json:"node_state,omitempty"`
	JobType              string               `protobuf:"bytes,8,opt,name=job_type,json=jobType,proto3" json:"job_type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*NodeDetectJobInfo) Descriptor 

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

func (*NodeDetectJobInfo) GetJobEndTime 

func (m *NodeDetectJobInfo) GetJobEndTime() *timestamp.Timestamp

func (*NodeDetectJobInfo) GetJobId 

func (m *NodeDetectJobInfo) GetJobId() string

func (*NodeDetectJobInfo) GetJobType 

func (m *NodeDetectJobInfo) GetJobType() string

func (*NodeDetectJobInfo) GetNodeId 

func (m *NodeDetectJobInfo) GetNodeId() string

func (*NodeDetectJobInfo) GetNodeState 

func (m *NodeDetectJobInfo) GetNodeState() string

func (*NodeDetectJobInfo) GetNodeStatus 

func (m *NodeDetectJobInfo) GetNodeStatus() string

func (*NodeDetectJobInfo) GetPlatformName 

func (m *NodeDetectJobInfo) GetPlatformName() string

func (*NodeDetectJobInfo) GetPlatformRelease 

func (m *NodeDetectJobInfo) GetPlatformRelease() string

func (*NodeDetectJobInfo) ProtoMessage 

func (*NodeDetectJobInfo) ProtoMessage()

func (*NodeDetectJobInfo) Reset 

func (m *NodeDetectJobInfo) Reset()

func (*NodeDetectJobInfo) String 

func (m *NodeDetectJobInfo) String() string

func (*NodeDetectJobInfo) XXX_DiscardUnknown 

func (m *NodeDetectJobInfo) XXX_DiscardUnknown()

func (*NodeDetectJobInfo) XXX_Marshal 

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

func (*NodeDetectJobInfo) XXX_Merge 

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

func (*NodeDetectJobInfo) XXX_Size 

func (m *NodeDetectJobInfo) XXX_Size() int

func (*NodeDetectJobInfo) XXX_Unmarshal 

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

type NodeError 

type NodeError struct {
	NodeId               string   `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	ConnectionError      string   `protobuf:"bytes,2,opt,name=connection_error,json=connectionError,proto3" json:"connection_error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NodeError) Descriptor 

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

func (*NodeError) GetConnectionError 

func (m *NodeError) GetConnectionError() string

func (*NodeError) GetNodeId 

func (m *NodeError) GetNodeId() string

func (*NodeError) ProtoMessage 

func (*NodeError) ProtoMessage()

func (*NodeError) Reset 

func (m *NodeError) Reset()

func (*NodeError) String 

func (m *NodeError) String() string

func (*NodeError) XXX_DiscardUnknown 

func (m *NodeError) XXX_DiscardUnknown()

func (*NodeError) XXX_Marshal 

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

func (*NodeError) XXX_Merge 

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

func (*NodeError) XXX_Size 

func (m *NodeError) XXX_Size() int

func (*NodeError) XXX_Unmarshal 

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

type NodeSecrets 

type NodeSecrets struct {
	User                 string   `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	Password             string   `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	KeyFiles             []string `protobuf:"bytes,3,rep,name=key_files,json=keyFiles,proto3" json:"key_files,omitempty"`
	SudoPassword         string   `protobuf:"bytes,4,opt,name=sudo_password,json=sudoPassword,proto3" json:"sudo_password,omitempty"`
	SudoOptions          string   `protobuf:"bytes,5,opt,name=sudo_options,json=sudoOptions,proto3" json:"sudo_options,omitempty"`
	AwsUser              string   `protobuf:"bytes,6,opt,name=aws_user,json=awsUser,proto3" json:"aws_user,omitempty"`
	AwsPassword          string   `protobuf:"bytes,7,opt,name=aws_password,json=awsPassword,proto3" json:"aws_password,omitempty"`
	AzureClientId        string   `protobuf:"bytes,8,opt,name=azure_client_id,json=azureClientId,proto3" json:"azure_client_id,omitempty"`
	AzureClientSecret    string   `protobuf:"bytes,9,opt,name=azure_client_secret,json=azureClientSecret,proto3" json:"azure_client_secret,omitempty"`
	AzureTenantId        string   `protobuf:"bytes,10,opt,name=azure_tenant_id,json=azureTenantId,proto3" json:"azure_tenant_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

TODO: there is clearly some repetition between these two msg types that needs to be addressed; it will involve some refactoring that i'm afraid will bloat the current change i am working on, so leaving that for another day

func (*NodeSecrets) Descriptor 

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

func (*NodeSecrets) GetAwsPassword 

func (m *NodeSecrets) GetAwsPassword() string

func (*NodeSecrets) GetAwsUser 

func (m *NodeSecrets) GetAwsUser() string

func (*NodeSecrets) GetAzureClientId 

func (m *NodeSecrets) GetAzureClientId() string

func (*NodeSecrets) GetAzureClientSecret 

func (m *NodeSecrets) GetAzureClientSecret() string

func (*NodeSecrets) GetAzureTenantId 

func (m *NodeSecrets) GetAzureTenantId() string

func (*NodeSecrets) GetKeyFiles 

func (m *NodeSecrets) GetKeyFiles() []string

func (*NodeSecrets) GetPassword 

func (m *NodeSecrets) GetPassword() string

func (*NodeSecrets) GetSudoOptions 

func (m *NodeSecrets) GetSudoOptions() string

func (*NodeSecrets) GetSudoPassword 

func (m *NodeSecrets) GetSudoPassword() string

func (*NodeSecrets) GetUser 

func (m *NodeSecrets) GetUser() string

func (*NodeSecrets) ProtoMessage 

func (*NodeSecrets) ProtoMessage()

func (*NodeSecrets) Reset 

func (m *NodeSecrets) Reset()

func (*NodeSecrets) String 

func (m *NodeSecrets) String() string

func (*NodeSecrets) XXX_DiscardUnknown 

func (m *NodeSecrets) XXX_DiscardUnknown()

func (*NodeSecrets) XXX_Marshal 

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

func (*NodeSecrets) XXX_Merge 

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

func (*NodeSecrets) XXX_Size 

func (m *NodeSecrets) XXX_Size() int

func (*NodeSecrets) XXX_Unmarshal 

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

type Nodes 

type Nodes struct {
	Nodes                []*Node  `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
	Total                int32    `protobuf:"varint,20,opt,name=total,proto3" json:"total,omitempty"`
	TotalUnreachable     int32    `protobuf:"varint,21,opt,name=total_unreachable,json=totalUnreachable,proto3" json:"total_unreachable,omitempty"`
	TotalReachable       int32    `protobuf:"varint,22,opt,name=total_reachable,json=totalReachable,proto3" json:"total_reachable,omitempty"`
	TotalUnknown         int32    `protobuf:"varint,23,opt,name=total_unknown,json=totalUnknown,proto3" json:"total_unknown,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() []*Node

func (*Nodes) GetTotal 

func (m *Nodes) GetTotal() int32

func (*Nodes) GetTotalReachable 

func (m *Nodes) GetTotalReachable() int32

func (*Nodes) GetTotalUnknown 

func (m *Nodes) GetTotalUnknown() int32

func (*Nodes) GetTotalUnreachable 

func (m *Nodes) GetTotalUnreachable() 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 NodesServiceClient 

type NodesServiceClient interface {
	Create(ctx context.Context, in *Node, opts ...grpc.CallOption) (*Id, error)
	Read(ctx context.Context, in *Id, opts ...grpc.CallOption) (*Node, error)
	Update(ctx context.Context, in *Node, opts ...grpc.CallOption) (*empty.Empty, error)
	Delete(ctx context.Context, in *Id, opts ...grpc.CallOption) (*empty.Empty, error)
	List(ctx context.Context, in *Query, opts ...grpc.CallOption) (*Nodes, error)
	BulkDelete(ctx context.Context, in *Query, opts ...grpc.CallOption) (*BulkDeleteResponse, error)
	BulkCreate(ctx context.Context, in *Nodes, opts ...grpc.CallOption) (*Ids, error)
	UpdateNodeDetectInfo(ctx context.Context, in *NodeDetectJobInfo, opts ...grpc.CallOption) (*empty.Empty, error)
	UpdateNodeConnectionError(ctx context.Context, in *NodeError, opts ...grpc.CallOption) (*empty.Empty, error)
	BulkDeleteById(ctx context.Context, in *Ids, opts ...grpc.CallOption) (*BulkDeleteResponse, error)
}

NodesServiceClient is the client API for NodesService service.

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

func NewNodesServiceClient 

func NewNodesServiceClient(cc *grpc.ClientConn) NodesServiceClient

type NodesServiceServer 

type NodesServiceServer interface {
	Create(context.Context, *Node) (*Id, error)
	Read(context.Context, *Id) (*Node, error)
	Update(context.Context, *Node) (*empty.Empty, error)
	Delete(context.Context, *Id) (*empty.Empty, error)
	List(context.Context, *Query) (*Nodes, error)
	BulkDelete(context.Context, *Query) (*BulkDeleteResponse, error)
	BulkCreate(context.Context, *Nodes) (*Ids, error)
	UpdateNodeDetectInfo(context.Context, *NodeDetectJobInfo) (*empty.Empty, error)
	UpdateNodeConnectionError(context.Context, *NodeError) (*empty.Empty, error)
	BulkDeleteById(context.Context, *Ids) (*BulkDeleteResponse, error)
}

NodesServiceServer is the server API for NodesService service.

type Query 

type Query struct {
	Filters              []*common.Filter `protobuf:"bytes,20,rep,name=filters,proto3" json:"filters,omitempty"`
	Order                Query_OrderType  `` /* 129-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) GetFilters 

func (m *Query) GetFilters() []*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

type RerunResponse 

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

func (*RerunResponse) Descriptor 

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

func (*RerunResponse) ProtoMessage 

func (*RerunResponse) ProtoMessage()

func (*RerunResponse) Reset 

func (m *RerunResponse) Reset()

func (*RerunResponse) String 

func (m *RerunResponse) String() string

func (*RerunResponse) XXX_DiscardUnknown 

func (m *RerunResponse) XXX_DiscardUnknown()

func (*RerunResponse) XXX_Marshal 

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

func (*RerunResponse) XXX_Merge 

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

func (*RerunResponse) XXX_Size 

func (m *RerunResponse) XXX_Size() int

func (*RerunResponse) XXX_Unmarshal 

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

type ResultsRow 

type ResultsRow struct {
	NodeId               string               `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	ReportId             string               `protobuf:"bytes,2,opt,name=report_id,json=reportId,proto3" json:"report_id,omitempty"`
	Status               string               `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	Result               string               `protobuf:"bytes,4,opt,name=result,proto3" json:"result,omitempty"`
	JobId                string               `protobuf:"bytes,5,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	StartTime            *timestamp.Timestamp `protobuf:"bytes,20,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	EndTime              *timestamp.Timestamp `protobuf:"bytes,21,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*ResultsRow) Descriptor 

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

func (*ResultsRow) GetEndTime 

func (m *ResultsRow) GetEndTime() *timestamp.Timestamp

func (*ResultsRow) GetJobId 

func (m *ResultsRow) GetJobId() string

func (*ResultsRow) GetNodeId 

func (m *ResultsRow) GetNodeId() string

func (*ResultsRow) GetReportId 

func (m *ResultsRow) GetReportId() string

func (*ResultsRow) GetResult 

func (m *ResultsRow) GetResult() string

func (*ResultsRow) GetStartTime 

func (m *ResultsRow) GetStartTime() *timestamp.Timestamp

func (*ResultsRow) GetStatus 

func (m *ResultsRow) GetStatus() string

func (*ResultsRow) ProtoMessage 

func (*ResultsRow) ProtoMessage()

func (*ResultsRow) Reset 

func (m *ResultsRow) Reset()

func (*ResultsRow) String 

func (m *ResultsRow) String() string

func (*ResultsRow) XXX_DiscardUnknown 

func (m *ResultsRow) XXX_DiscardUnknown()

func (*ResultsRow) XXX_Marshal 

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

func (*ResultsRow) XXX_Merge 

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

func (*ResultsRow) XXX_Size 

func (m *ResultsRow) XXX_Size() int

func (*ResultsRow) XXX_Unmarshal 

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

type TargetConfig 

type TargetConfig struct {
	Secrets              []string       `protobuf:"bytes,20,rep,name=secrets,proto3" json:"secrets,omitempty"`
	Format               string         `protobuf:"bytes,21,opt,name=format,proto3" json:"format,omitempty"`
	Backend              string         `protobuf:"bytes,22,opt,name=backend,proto3" json:"backend,omitempty"`
	Host                 string         `protobuf:"bytes,23,opt,name=host,proto3" json:"host,omitempty"`
	Port                 int32          `protobuf:"varint,24,opt,name=port,proto3" json:"port,omitempty"`
	Path                 string         `protobuf:"bytes,25,opt,name=path,proto3" json:"path,omitempty"`
	Sudo                 bool           `protobuf:"varint,26,opt,name=sudo,proto3" json:"sudo,omitempty"`
	Ssl                  bool           `protobuf:"varint,27,opt,name=ssl,proto3" json:"ssl,omitempty"`
	SelfSigned           bool           `protobuf:"varint,28,opt,name=self_signed,json=selfSigned,proto3" json:"self_signed,omitempty"`
	User                 string         `protobuf:"bytes,29,opt,name=user,proto3" json:"user,omitempty"`
	Password             string         `protobuf:"bytes,30,opt,name=password,proto3" json:"password,omitempty"`
	KeyFiles             []string       `protobuf:"bytes,31,rep,name=key_files,json=keyFiles,proto3" json:"key_files,omitempty"`
	SudoPassword         string         `protobuf:"bytes,32,opt,name=sudo_password,json=sudoPassword,proto3" json:"sudo_password,omitempty"`
	SudoOptions          string         `protobuf:"bytes,33,opt,name=sudo_options,json=sudoOptions,proto3" json:"sudo_options,omitempty"`
	Region               string         `protobuf:"bytes,34,opt,name=region,proto3" json:"region,omitempty"`
	SubscriptionId       string         `protobuf:"bytes,35,opt,name=subscription_id,json=subscriptionId,proto3" json:"subscription_id,omitempty"`
	AwsUser              string         `protobuf:"bytes,36,opt,name=aws_user,json=awsUser,proto3" json:"aws_user,omitempty"`
	AwsPassword          string         `protobuf:"bytes,37,opt,name=aws_password,json=awsPassword,proto3" json:"aws_password,omitempty"`
	SecretsArr           []*NodeSecrets `protobuf:"bytes,38,rep,name=secrets_arr,json=secretsArr,proto3" json:"secrets_arr,omitempty"`
	GcpCredsJson         string         `protobuf:"bytes,39,opt,name=gcp_creds_json,json=gcpCredsJson,proto3" json:"gcp_creds_json,omitempty"`
	Hosts                []string       `protobuf:"bytes,40,rep,name=hosts,proto3" json:"hosts,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*TargetConfig) Descriptor 

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

func (*TargetConfig) GetAwsPassword 

func (m *TargetConfig) GetAwsPassword() string

func (*TargetConfig) GetAwsUser 

func (m *TargetConfig) GetAwsUser() string

func (*TargetConfig) GetBackend 

func (m *TargetConfig) GetBackend() string

func (*TargetConfig) GetFormat 

func (m *TargetConfig) GetFormat() string

func (*TargetConfig) GetGcpCredsJson 

func (m *TargetConfig) GetGcpCredsJson() string

func (*TargetConfig) GetHost 

func (m *TargetConfig) GetHost() string

func (*TargetConfig) GetHosts 

func (m *TargetConfig) GetHosts() []string

func (*TargetConfig) GetKeyFiles 

func (m *TargetConfig) GetKeyFiles() []string

func (*TargetConfig) GetPassword 

func (m *TargetConfig) GetPassword() string

func (*TargetConfig) GetPath 

func (m *TargetConfig) GetPath() string

func (*TargetConfig) GetPort 

func (m *TargetConfig) GetPort() int32

func (*TargetConfig) GetRegion 

func (m *TargetConfig) GetRegion() string

func (*TargetConfig) GetSecrets 

func (m *TargetConfig) GetSecrets() []string

func (*TargetConfig) GetSecretsArr 

func (m *TargetConfig) GetSecretsArr() []*NodeSecrets

func (*TargetConfig) GetSelfSigned 

func (m *TargetConfig) GetSelfSigned() bool

func (*TargetConfig) GetSsl 

func (m *TargetConfig) GetSsl() bool

func (*TargetConfig) GetSubscriptionId 

func (m *TargetConfig) GetSubscriptionId() string

func (*TargetConfig) GetSudo 

func (m *TargetConfig) GetSudo() bool

func (*TargetConfig) GetSudoOptions 

func (m *TargetConfig) GetSudoOptions() string

func (*TargetConfig) GetSudoPassword 

func (m *TargetConfig) GetSudoPassword() string

func (*TargetConfig) GetUser 

func (m *TargetConfig) GetUser() string

func (*TargetConfig) ProtoMessage 

func (*TargetConfig) ProtoMessage()

func (*TargetConfig) Reset 

func (m *TargetConfig) Reset()

func (*TargetConfig) String 

func (m *TargetConfig) String() string

func (*TargetConfig) XXX_DiscardUnknown 

func (m *TargetConfig) XXX_DiscardUnknown()

func (*TargetConfig) XXX_Marshal 

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

func (*TargetConfig) XXX_Merge 

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

func (*TargetConfig) XXX_Size 

func (m *TargetConfig) XXX_Size() int

func (*TargetConfig) XXX_Unmarshal 

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

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.