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