Documentation
¶
Overview ¶
Package manager is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- Variables
- func RegisterNodeManagerServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterNodeManagerServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client NodeManagerServiceClient) error
- func RegisterNodeManagerServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterNodeManagerServiceServer(s *grpc.Server, srv NodeManagerServiceServer)
- type ConnectResponse
- func (*ConnectResponse) Descriptor() ([]byte, []int)
- func (*ConnectResponse) ProtoMessage()
- func (m *ConnectResponse) Reset()
- func (m *ConnectResponse) String() string
- func (m *ConnectResponse) XXX_DiscardUnknown()
- func (m *ConnectResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ConnectResponse) XXX_Merge(src proto.Message)
- func (m *ConnectResponse) XXX_Size() int
- func (m *ConnectResponse) XXX_Unmarshal(b []byte) error
- type CredentialsByTags
- func (*CredentialsByTags) Descriptor() ([]byte, []int)
- func (m *CredentialsByTags) GetCredentialIds() []string
- func (m *CredentialsByTags) GetTagKey() string
- func (m *CredentialsByTags) GetTagValue() string
- func (*CredentialsByTags) ProtoMessage()
- func (m *CredentialsByTags) Reset()
- func (m *CredentialsByTags) String() string
- func (m *CredentialsByTags) XXX_DiscardUnknown()
- func (m *CredentialsByTags) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *CredentialsByTags) XXX_Merge(src proto.Message)
- func (m *CredentialsByTags) XXX_Size() int
- func (m *CredentialsByTags) XXX_Unmarshal(b []byte) error
- type FieldQuery
- func (*FieldQuery) Descriptor() ([]byte, []int)
- func (m *FieldQuery) GetField() string
- func (m *FieldQuery) GetNodeManagerId() string
- func (m *FieldQuery) GetQuery() *Query
- func (*FieldQuery) ProtoMessage()
- func (m *FieldQuery) Reset()
- func (m *FieldQuery) String() string
- func (m *FieldQuery) XXX_DiscardUnknown()
- func (m *FieldQuery) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *FieldQuery) XXX_Merge(src proto.Message)
- func (m *FieldQuery) XXX_Size() int
- func (m *FieldQuery) XXX_Unmarshal(b []byte) error
- type Fields
- func (*Fields) Descriptor() ([]byte, []int)
- func (m *Fields) GetFields() []string
- func (*Fields) ProtoMessage()
- func (m *Fields) Reset()
- func (m *Fields) String() string
- func (m *Fields) XXX_DiscardUnknown()
- func (m *Fields) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Fields) XXX_Merge(src proto.Message)
- func (m *Fields) XXX_Size() int
- func (m *Fields) XXX_Unmarshal(b []byte) error
- type Id
- func (*Id) Descriptor() ([]byte, []int)
- func (m *Id) GetId() string
- func (*Id) ProtoMessage()
- func (m *Id) Reset()
- func (m *Id) String() string
- func (m *Id) XXX_DiscardUnknown()
- func (m *Id) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Id) XXX_Merge(src proto.Message)
- func (m *Id) XXX_Size() int
- func (m *Id) XXX_Unmarshal(b []byte) error
- type Ids
- func (*Ids) Descriptor() ([]byte, []int)
- func (m *Ids) GetIds() []*Id
- func (*Ids) ProtoMessage()
- func (m *Ids) Reset()
- func (m *Ids) String() string
- func (m *Ids) XXX_DiscardUnknown()
- func (m *Ids) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Ids) XXX_Merge(src proto.Message)
- func (m *Ids) XXX_Size() int
- func (m *Ids) XXX_Unmarshal(b []byte) error
- type NodeManager
- func (*NodeManager) Descriptor() ([]byte, []int)
- func (m *NodeManager) GetAccountId() string
- func (m *NodeManager) GetCredentialData() []*common.Kv
- func (m *NodeManager) GetCredentialId() string
- func (m *NodeManager) GetDateAdded() *timestamp.Timestamp
- func (m *NodeManager) GetId() string
- func (m *NodeManager) GetInstanceCredentials() []*CredentialsByTags
- func (m *NodeManager) GetName() string
- func (m *NodeManager) GetStatus() string
- func (m *NodeManager) GetType() string
- func (*NodeManager) ProtoMessage()
- func (m *NodeManager) Reset()
- func (m *NodeManager) String() string
- func (m *NodeManager) XXX_DiscardUnknown()
- func (m *NodeManager) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *NodeManager) XXX_Merge(src proto.Message)
- func (m *NodeManager) XXX_Size() int
- func (m *NodeManager) XXX_Unmarshal(b []byte) error
- type NodeManagerServiceClient
- type NodeManagerServiceServer
- type NodeManagerServiceServerMock
- func (m *NodeManagerServiceServerMock) Connect(ctx context.Context, req *Id) (*ConnectResponse, error)
- func (m *NodeManagerServiceServerMock) Create(ctx context.Context, req *NodeManager) (*Ids, error)
- func (m *NodeManagerServiceServerMock) Delete(ctx context.Context, req *Id) (*empty.Empty, error)
- func (m *NodeManagerServiceServerMock) DeleteWithNodeStateStopped(ctx context.Context, req *Id) (*empty.Empty, error)
- func (m *NodeManagerServiceServerMock) DeleteWithNodeStateTerminated(ctx context.Context, req *Id) (*empty.Empty, error)
- func (m *NodeManagerServiceServerMock) DeleteWithNodes(ctx context.Context, req *Id) (*Ids, error)
- func (m *NodeManagerServiceServerMock) List(ctx context.Context, req *Query) (*NodeManagers, error)
- func (m *NodeManagerServiceServerMock) Read(ctx context.Context, req *Id) (*NodeManager, error)
- func (m *NodeManagerServiceServerMock) Reset()
- func (m *NodeManagerServiceServerMock) SearchNodeFields(ctx context.Context, req *FieldQuery) (*Fields, error)
- func (m *NodeManagerServiceServerMock) SearchNodes(ctx context.Context, req *NodeQuery) (*Nodes, error)
- func (m *NodeManagerServiceServerMock) Update(ctx context.Context, req *NodeManager) (*empty.Empty, error)
- type NodeManagers
- func (*NodeManagers) Descriptor() ([]byte, []int)
- func (m *NodeManagers) GetManagers() []*NodeManager
- func (m *NodeManagers) GetTotal() int32
- func (*NodeManagers) ProtoMessage()
- func (m *NodeManagers) Reset()
- func (m *NodeManagers) String() string
- func (m *NodeManagers) XXX_DiscardUnknown()
- func (m *NodeManagers) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *NodeManagers) XXX_Merge(src proto.Message)
- func (m *NodeManagers) XXX_Size() int
- func (m *NodeManagers) XXX_Unmarshal(b []byte) error
- type NodeQuery
- func (*NodeQuery) Descriptor() ([]byte, []int)
- func (m *NodeQuery) GetNodeManagerId() string
- func (m *NodeQuery) GetQuery() *Query
- func (*NodeQuery) ProtoMessage()
- func (m *NodeQuery) Reset()
- func (m *NodeQuery) String() string
- func (m *NodeQuery) XXX_DiscardUnknown()
- func (m *NodeQuery) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *NodeQuery) XXX_Merge(src proto.Message)
- func (m *NodeQuery) XXX_Size() int
- func (m *NodeQuery) XXX_Unmarshal(b []byte) error
- type Nodes
- func (*Nodes) Descriptor() ([]byte, []int)
- func (m *Nodes) GetNodes() []string
- func (m *Nodes) GetTotal() int32
- func (*Nodes) ProtoMessage()
- func (m *Nodes) Reset()
- func (m *Nodes) String() string
- func (m *Nodes) XXX_DiscardUnknown()
- func (m *Nodes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Nodes) XXX_Merge(src proto.Message)
- func (m *Nodes) XXX_Size() int
- func (m *Nodes) XXX_Unmarshal(b []byte) error
- type Query
- func (*Query) Descriptor() ([]byte, []int)
- func (m *Query) GetFilterMap() []*common.Filter
- func (m *Query) GetOrder() Query_OrderType
- func (m *Query) GetPage() int32
- func (m *Query) GetPerPage() int32
- func (m *Query) GetSort() string
- func (*Query) ProtoMessage()
- func (m *Query) Reset()
- func (m *Query) String() string
- func (m *Query) XXX_DiscardUnknown()
- func (m *Query) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Query) XXX_Merge(src proto.Message)
- func (m *Query) XXX_Size() int
- func (m *Query) XXX_Unmarshal(b []byte) error
- type Query_OrderType
Constants ¶
This section is empty.
Variables ¶
var Query_OrderType_name = map[int32]string{
0: "ASC",
1: "DESC",
}
var Query_OrderType_value = map[string]int32{
"ASC": 0,
"DESC": 1,
}
Functions ¶
func RegisterNodeManagerServiceHandler ¶
func RegisterNodeManagerServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
RegisterNodeManagerServiceHandler registers the http handlers for service NodeManagerService to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterNodeManagerServiceHandlerClient ¶
func RegisterNodeManagerServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client NodeManagerServiceClient) error
RegisterNodeManagerServiceHandlerClient registers the http handlers for service NodeManagerService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "NodeManagerServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "NodeManagerServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "NodeManagerServiceClient" to call the correct interceptors.
func RegisterNodeManagerServiceHandlerFromEndpoint ¶
func RegisterNodeManagerServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterNodeManagerServiceHandlerFromEndpoint is same as RegisterNodeManagerServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterNodeManagerServiceServer ¶
func RegisterNodeManagerServiceServer(s *grpc.Server, srv NodeManagerServiceServer)
Types ¶
type ConnectResponse ¶
type ConnectResponse struct {
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*ConnectResponse) Descriptor ¶
func (*ConnectResponse) Descriptor() ([]byte, []int)
func (*ConnectResponse) ProtoMessage ¶
func (*ConnectResponse) ProtoMessage()
func (*ConnectResponse) Reset ¶
func (m *ConnectResponse) Reset()
func (*ConnectResponse) String ¶
func (m *ConnectResponse) String() string
func (*ConnectResponse) XXX_DiscardUnknown ¶
func (m *ConnectResponse) XXX_DiscardUnknown()
func (*ConnectResponse) XXX_Marshal ¶
func (m *ConnectResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ConnectResponse) XXX_Merge ¶
func (dst *ConnectResponse) XXX_Merge(src proto.Message)
func (*ConnectResponse) XXX_Size ¶
func (m *ConnectResponse) XXX_Size() int
func (*ConnectResponse) XXX_Unmarshal ¶
func (m *ConnectResponse) XXX_Unmarshal(b []byte) error
type CredentialsByTags ¶
type CredentialsByTags struct {
TagKey string `protobuf:"bytes,20,opt,name=tag_key,json=tagKey,proto3" json:"tag_key,omitempty"`
TagValue string `protobuf:"bytes,21,opt,name=tag_value,json=tagValue,proto3" json:"tag_value,omitempty"`
CredentialIds []string `protobuf:"bytes,22,rep,name=credential_ids,json=credentialIds,proto3" json:"credential_ids,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*CredentialsByTags) Descriptor ¶
func (*CredentialsByTags) Descriptor() ([]byte, []int)
func (*CredentialsByTags) GetCredentialIds ¶
func (m *CredentialsByTags) GetCredentialIds() []string
func (*CredentialsByTags) GetTagKey ¶
func (m *CredentialsByTags) GetTagKey() string
func (*CredentialsByTags) GetTagValue ¶
func (m *CredentialsByTags) GetTagValue() string
func (*CredentialsByTags) ProtoMessage ¶
func (*CredentialsByTags) ProtoMessage()
func (*CredentialsByTags) Reset ¶
func (m *CredentialsByTags) Reset()
func (*CredentialsByTags) String ¶
func (m *CredentialsByTags) String() string
func (*CredentialsByTags) XXX_DiscardUnknown ¶
func (m *CredentialsByTags) XXX_DiscardUnknown()
func (*CredentialsByTags) XXX_Marshal ¶
func (m *CredentialsByTags) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CredentialsByTags) XXX_Merge ¶
func (dst *CredentialsByTags) XXX_Merge(src proto.Message)
func (*CredentialsByTags) XXX_Size ¶
func (m *CredentialsByTags) XXX_Size() int
func (*CredentialsByTags) XXX_Unmarshal ¶
func (m *CredentialsByTags) XXX_Unmarshal(b []byte) error
type FieldQuery ¶
type FieldQuery struct {
Query *Query `protobuf:"bytes,20,opt,name=query,proto3" json:"query,omitempty"`
Field string `protobuf:"bytes,21,opt,name=field,proto3" json:"field,omitempty"`
NodeManagerId string `protobuf:"bytes,22,opt,name=node_manager_id,json=nodeManagerId,proto3" json:"node_manager_id,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*FieldQuery) Descriptor ¶
func (*FieldQuery) Descriptor() ([]byte, []int)
func (*FieldQuery) GetField ¶
func (m *FieldQuery) GetField() string
func (*FieldQuery) GetNodeManagerId ¶
func (m *FieldQuery) GetNodeManagerId() string
func (*FieldQuery) GetQuery ¶
func (m *FieldQuery) GetQuery() *Query
func (*FieldQuery) ProtoMessage ¶
func (*FieldQuery) ProtoMessage()
func (*FieldQuery) Reset ¶
func (m *FieldQuery) Reset()
func (*FieldQuery) String ¶
func (m *FieldQuery) String() string
func (*FieldQuery) XXX_DiscardUnknown ¶
func (m *FieldQuery) XXX_DiscardUnknown()
func (*FieldQuery) XXX_Marshal ¶
func (m *FieldQuery) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FieldQuery) XXX_Merge ¶
func (dst *FieldQuery) XXX_Merge(src proto.Message)
func (*FieldQuery) XXX_Size ¶
func (m *FieldQuery) XXX_Size() int
func (*FieldQuery) XXX_Unmarshal ¶
func (m *FieldQuery) XXX_Unmarshal(b []byte) error
type Fields ¶
type Fields struct {
Fields []string `protobuf:"bytes,1,rep,name=fields,proto3" json:"fields,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*Fields) Descriptor ¶
func (*Fields) ProtoMessage ¶
func (*Fields) ProtoMessage()
func (*Fields) XXX_DiscardUnknown ¶
func (m *Fields) XXX_DiscardUnknown()
func (*Fields) XXX_Marshal ¶
func (*Fields) XXX_Unmarshal ¶
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) ProtoMessage ¶
func (*Id) ProtoMessage()
func (*Id) XXX_DiscardUnknown ¶
func (m *Id) XXX_DiscardUnknown()
func (*Id) XXX_Unmarshal ¶
type Ids ¶
type Ids struct {
Ids []*Id `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*Ids) Descriptor ¶
func (*Ids) ProtoMessage ¶
func (*Ids) ProtoMessage()
func (*Ids) XXX_DiscardUnknown ¶
func (m *Ids) XXX_DiscardUnknown()
func (*Ids) XXX_Unmarshal ¶
type NodeManager ¶
type NodeManager struct {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
CredentialId string `protobuf:"bytes,20,opt,name=credential_id,json=credentialId,proto3" json:"credential_id,omitempty"`
InstanceCredentials []*CredentialsByTags `protobuf:"bytes,21,rep,name=instance_credentials,json=instanceCredentials,proto3" json:"instance_credentials,omitempty"`
Status string `protobuf:"bytes,22,opt,name=status,proto3" json:"status,omitempty"`
AccountId string `protobuf:"bytes,24,opt,name=account_id,json=accountId,proto3" json:"account_id,omitempty"`
DateAdded *timestamp.Timestamp `protobuf:"bytes,25,opt,name=date_added,json=dateAdded,proto3" json:"date_added,omitempty"`
CredentialData []*common.Kv `protobuf:"bytes,26,rep,name=credential_data,json=credentialData,proto3" json:"credential_data,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*NodeManager) Descriptor ¶
func (*NodeManager) Descriptor() ([]byte, []int)
func (*NodeManager) GetAccountId ¶
func (m *NodeManager) GetAccountId() string
func (*NodeManager) GetCredentialData ¶
func (m *NodeManager) GetCredentialData() []*common.Kv
func (*NodeManager) GetCredentialId ¶
func (m *NodeManager) GetCredentialId() string
func (*NodeManager) GetDateAdded ¶
func (m *NodeManager) GetDateAdded() *timestamp.Timestamp
func (*NodeManager) GetId ¶
func (m *NodeManager) GetId() string
func (*NodeManager) GetInstanceCredentials ¶
func (m *NodeManager) GetInstanceCredentials() []*CredentialsByTags
func (*NodeManager) GetName ¶
func (m *NodeManager) GetName() string
func (*NodeManager) GetStatus ¶
func (m *NodeManager) GetStatus() string
func (*NodeManager) GetType ¶
func (m *NodeManager) GetType() string
func (*NodeManager) ProtoMessage ¶
func (*NodeManager) ProtoMessage()
func (*NodeManager) Reset ¶
func (m *NodeManager) Reset()
func (*NodeManager) String ¶
func (m *NodeManager) String() string
func (*NodeManager) XXX_DiscardUnknown ¶
func (m *NodeManager) XXX_DiscardUnknown()
func (*NodeManager) XXX_Marshal ¶
func (m *NodeManager) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NodeManager) XXX_Merge ¶
func (dst *NodeManager) XXX_Merge(src proto.Message)
func (*NodeManager) XXX_Size ¶
func (m *NodeManager) XXX_Size() int
func (*NodeManager) XXX_Unmarshal ¶
func (m *NodeManager) XXX_Unmarshal(b []byte) error
type NodeManagerServiceClient ¶
type NodeManagerServiceClient interface {
Create(ctx context.Context, in *NodeManager, opts ...grpc.CallOption) (*Ids, error)
Read(ctx context.Context, in *Id, opts ...grpc.CallOption) (*NodeManager, error)
Update(ctx context.Context, in *NodeManager, opts ...grpc.CallOption) (*empty.Empty, error)
Delete(ctx context.Context, in *Id, opts ...grpc.CallOption) (*empty.Empty, error)
DeleteWithNodes(ctx context.Context, in *Id, opts ...grpc.CallOption) (*Ids, error)
DeleteWithNodeStateStopped(ctx context.Context, in *Id, opts ...grpc.CallOption) (*empty.Empty, error)
DeleteWithNodeStateTerminated(ctx context.Context, in *Id, opts ...grpc.CallOption) (*empty.Empty, error)
List(ctx context.Context, in *Query, opts ...grpc.CallOption) (*NodeManagers, error)
SearchNodeFields(ctx context.Context, in *FieldQuery, opts ...grpc.CallOption) (*Fields, error)
SearchNodes(ctx context.Context, in *NodeQuery, opts ...grpc.CallOption) (*Nodes, error)
Connect(ctx context.Context, in *Id, opts ...grpc.CallOption) (*ConnectResponse, error)
}
NodeManagerServiceClient is the client API for NodeManagerService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewNodeManagerServiceClient ¶
func NewNodeManagerServiceClient(cc *grpc.ClientConn) NodeManagerServiceClient
type NodeManagerServiceServer ¶
type NodeManagerServiceServer interface {
Create(context.Context, *NodeManager) (*Ids, error)
Read(context.Context, *Id) (*NodeManager, error)
Update(context.Context, *NodeManager) (*empty.Empty, error)
Delete(context.Context, *Id) (*empty.Empty, error)
DeleteWithNodes(context.Context, *Id) (*Ids, error)
DeleteWithNodeStateStopped(context.Context, *Id) (*empty.Empty, error)
DeleteWithNodeStateTerminated(context.Context, *Id) (*empty.Empty, error)
List(context.Context, *Query) (*NodeManagers, error)
SearchNodeFields(context.Context, *FieldQuery) (*Fields, error)
SearchNodes(context.Context, *NodeQuery) (*Nodes, error)
Connect(context.Context, *Id) (*ConnectResponse, error)
}
NodeManagerServiceServer is the server API for NodeManagerService service.
type NodeManagerServiceServerMock ¶
type NodeManagerServiceServerMock struct {
CreateFunc func(context.Context, *NodeManager) (*Ids, error)
ReadFunc func(context.Context, *Id) (*NodeManager, error)
UpdateFunc func(context.Context, *NodeManager) (*empty.Empty, error)
DeleteFunc func(context.Context, *Id) (*empty.Empty, error)
DeleteWithNodesFunc func(context.Context, *Id) (*Ids, error)
DeleteWithNodeStateStoppedFunc func(context.Context, *Id) (*empty.Empty, error)
DeleteWithNodeStateTerminatedFunc func(context.Context, *Id) (*empty.Empty, error)
ListFunc func(context.Context, *Query) (*NodeManagers, error)
SearchNodeFieldsFunc func(context.Context, *FieldQuery) (*Fields, error)
SearchNodesFunc func(context.Context, *NodeQuery) (*Nodes, error)
ConnectFunc func(context.Context, *Id) (*ConnectResponse, error)
// contains filtered or unexported fields
}
NodeManagerServiceServerMock is the mock-what-you-want struct that stubs all not-overridden methods with "not implemented" returns
func NewNodeManagerServiceServerMock ¶
func NewNodeManagerServiceServerMock() *NodeManagerServiceServerMock
NewNodeManagerServiceServerMock gives you a fresh instance of NodeManagerServiceServerMock.
func NewNodeManagerServiceServerMockWithoutValidation ¶
func NewNodeManagerServiceServerMockWithoutValidation() *NodeManagerServiceServerMock
NewNodeManagerServiceServerMockWithoutValidation gives you a fresh instance of NodeManagerServiceServerMock which does not attempt to validate requests before passing them to their respective '*Func'.
func (*NodeManagerServiceServerMock) Connect ¶
func (m *NodeManagerServiceServerMock) Connect(ctx context.Context, req *Id) (*ConnectResponse, error)
func (*NodeManagerServiceServerMock) Create ¶
func (m *NodeManagerServiceServerMock) Create(ctx context.Context, req *NodeManager) (*Ids, error)
func (*NodeManagerServiceServerMock) DeleteWithNodeStateStopped ¶
func (*NodeManagerServiceServerMock) DeleteWithNodeStateTerminated ¶
func (*NodeManagerServiceServerMock) DeleteWithNodes ¶
func (*NodeManagerServiceServerMock) List ¶
func (m *NodeManagerServiceServerMock) List(ctx context.Context, req *Query) (*NodeManagers, error)
func (*NodeManagerServiceServerMock) Read ¶
func (m *NodeManagerServiceServerMock) Read(ctx context.Context, req *Id) (*NodeManager, error)
func (*NodeManagerServiceServerMock) Reset ¶
func (m *NodeManagerServiceServerMock) Reset()
Reset resets all overridden functions
func (*NodeManagerServiceServerMock) SearchNodeFields ¶
func (m *NodeManagerServiceServerMock) SearchNodeFields(ctx context.Context, req *FieldQuery) (*Fields, error)
func (*NodeManagerServiceServerMock) SearchNodes ¶
func (*NodeManagerServiceServerMock) Update ¶
func (m *NodeManagerServiceServerMock) Update(ctx context.Context, req *NodeManager) (*empty.Empty, error)
type NodeManagers ¶
type NodeManagers struct {
Managers []*NodeManager `protobuf:"bytes,1,rep,name=managers,proto3" json:"managers,omitempty"`
Total int32 `protobuf:"varint,20,opt,name=total,proto3" json:"total,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*NodeManagers) Descriptor ¶
func (*NodeManagers) Descriptor() ([]byte, []int)
func (*NodeManagers) GetManagers ¶
func (m *NodeManagers) GetManagers() []*NodeManager
func (*NodeManagers) GetTotal ¶
func (m *NodeManagers) GetTotal() int32
func (*NodeManagers) ProtoMessage ¶
func (*NodeManagers) ProtoMessage()
func (*NodeManagers) Reset ¶
func (m *NodeManagers) Reset()
func (*NodeManagers) String ¶
func (m *NodeManagers) String() string
func (*NodeManagers) XXX_DiscardUnknown ¶
func (m *NodeManagers) XXX_DiscardUnknown()
func (*NodeManagers) XXX_Marshal ¶
func (m *NodeManagers) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NodeManagers) XXX_Merge ¶
func (dst *NodeManagers) XXX_Merge(src proto.Message)
func (*NodeManagers) XXX_Size ¶
func (m *NodeManagers) XXX_Size() int
func (*NodeManagers) XXX_Unmarshal ¶
func (m *NodeManagers) XXX_Unmarshal(b []byte) error
type NodeQuery ¶
type NodeQuery struct {
Query *Query `protobuf:"bytes,20,opt,name=query,proto3" json:"query,omitempty"`
NodeManagerId string `protobuf:"bytes,21,opt,name=node_manager_id,json=nodeManagerId,proto3" json:"node_manager_id,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*NodeQuery) Descriptor ¶
func (*NodeQuery) GetNodeManagerId ¶
func (*NodeQuery) ProtoMessage ¶
func (*NodeQuery) ProtoMessage()
func (*NodeQuery) XXX_DiscardUnknown ¶
func (m *NodeQuery) XXX_DiscardUnknown()
func (*NodeQuery) XXX_Marshal ¶
func (*NodeQuery) XXX_Unmarshal ¶
type Nodes ¶
type Nodes struct {
Nodes []string `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
Total int32 `protobuf:"varint,20,opt,name=total,proto3" json:"total,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*Nodes) Descriptor ¶
func (*Nodes) ProtoMessage ¶
func (*Nodes) ProtoMessage()
func (*Nodes) XXX_DiscardUnknown ¶
func (m *Nodes) XXX_DiscardUnknown()
func (*Nodes) XXX_Marshal ¶
func (*Nodes) XXX_Unmarshal ¶
type Query ¶
type Query struct {
FilterMap []*common.Filter `protobuf:"bytes,25,rep,name=filter_map,json=filterMap,proto3" json:"filter_map,omitempty"`
Order Query_OrderType `protobuf:"varint,21,opt,name=order,proto3,enum=chef.automate.api.nodes.manager.v1.Query_OrderType" json:"order,omitempty"`
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) GetFilterMap ¶
func (*Query) GetOrder ¶
func (m *Query) GetOrder() Query_OrderType
func (*Query) GetPerPage ¶
func (*Query) ProtoMessage ¶
func (*Query) ProtoMessage()
func (*Query) XXX_DiscardUnknown ¶
func (m *Query) XXX_DiscardUnknown()
func (*Query) XXX_Marshal ¶
func (*Query) XXX_Unmarshal ¶
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