Documentation
¶
Index ¶
- Variables
- func RegisterOrchestrationServiceServer(s grpc.ServiceRegistrar, srv OrchestrationServiceServer)
- type DeployRequest
- func (*DeployRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeployRequest) GetAuth() *fnapi.UserAuth
- func (x *DeployRequest) GetAws() *configuration.Configuration
- func (x *DeployRequest) GetPlan() *schema.DeployPlan
- func (*DeployRequest) ProtoMessage()
- func (x *DeployRequest) ProtoReflect() protoreflect.Message
- func (x *DeployRequest) Reset()
- func (x *DeployRequest) String() string
- type DeployResponse
- type DeploymentStatusRequest
- func (*DeploymentStatusRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeploymentStatusRequest) GetId() string
- func (x *DeploymentStatusRequest) GetLogLevel() int32
- func (*DeploymentStatusRequest) ProtoMessage()
- func (x *DeploymentStatusRequest) ProtoReflect() protoreflect.Message
- func (x *DeploymentStatusRequest) Reset()
- func (x *DeploymentStatusRequest) String() string
- type DeploymentStatusResponse
- func (*DeploymentStatusResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DeploymentStatusResponse) GetEvent() *orchestration.Event
- func (x *DeploymentStatusResponse) GetLog() *protolog.Log
- func (*DeploymentStatusResponse) ProtoMessage()
- func (x *DeploymentStatusResponse) ProtoReflect() protoreflect.Message
- func (x *DeploymentStatusResponse) Reset()
- func (x *DeploymentStatusResponse) String() string
- type GetOrchestratorVersionRequest
- func (*GetOrchestratorVersionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetOrchestratorVersionRequest) GetSkipCache() bool
- func (*GetOrchestratorVersionRequest) ProtoMessage()
- func (x *GetOrchestratorVersionRequest) ProtoReflect() protoreflect.Message
- func (x *GetOrchestratorVersionRequest) Reset()
- func (x *GetOrchestratorVersionRequest) String() string
- type GetOrchestratorVersionResponse
- func (*GetOrchestratorVersionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetOrchestratorVersionResponse) GetCurrent() *schema.Workspace_BinaryDigest
- func (x *GetOrchestratorVersionResponse) GetPinned() []*schema.Workspace_BinaryDigest
- func (*GetOrchestratorVersionResponse) ProtoMessage()
- func (x *GetOrchestratorVersionResponse) ProtoReflect() protoreflect.Message
- func (x *GetOrchestratorVersionResponse) Reset()
- func (x *GetOrchestratorVersionResponse) String() string
- type OrchestrationServiceClient
- type OrchestrationServiceServer
- type OrchestrationService_DeploymentStatusClient
- type OrchestrationService_DeploymentStatusServer
- type UnimplementedOrchestrationServiceServer
- func (UnimplementedOrchestrationServiceServer) Deploy(context.Context, *DeployRequest) (*DeployResponse, error)
- func (UnimplementedOrchestrationServiceServer) DeploymentStatus(*DeploymentStatusRequest, OrchestrationService_DeploymentStatusServer) error
- func (UnimplementedOrchestrationServiceServer) GetOrchestratorVersion(context.Context, *GetOrchestratorVersionRequest) (*GetOrchestratorVersionResponse, error)
- type UnsafeOrchestrationServiceServer
Constants ¶
This section is empty.
Variables ¶
var File_orchestration_proto_service_proto protoreflect.FileDescriptor
var OrchestrationService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "nsl.orchestration.OrchestrationService", HandlerType: (*OrchestrationServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Deploy", Handler: _OrchestrationService_Deploy_Handler, }, { MethodName: "GetOrchestratorVersion", Handler: _OrchestrationService_GetOrchestratorVersion_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "DeploymentStatus", Handler: _OrchestrationService_DeploymentStatus_Handler, ServerStreams: true, }, }, Metadata: "orchestration/proto/service.proto", }
OrchestrationService_ServiceDesc is the grpc.ServiceDesc for OrchestrationService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterOrchestrationServiceServer ¶
func RegisterOrchestrationServiceServer(s grpc.ServiceRegistrar, srv OrchestrationServiceServer)
Types ¶
type DeployRequest ¶
type DeployRequest struct { Plan *schema.DeployPlan `protobuf:"bytes,1,opt,name=plan,proto3" json:"plan,omitempty"` Aws *configuration.Configuration `protobuf:"bytes,4,opt,name=aws,proto3" json:"aws,omitempty"` Auth *fnapi.UserAuth `protobuf:"bytes,5,opt,name=auth,proto3" json:"auth,omitempty"` // Time-limited Namespace session. // contains filtered or unexported fields }
func (*DeployRequest) Descriptor
deprecated
func (*DeployRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeployRequest.ProtoReflect.Descriptor instead.
func (*DeployRequest) GetAuth ¶
func (x *DeployRequest) GetAuth() *fnapi.UserAuth
func (*DeployRequest) GetAws ¶
func (x *DeployRequest) GetAws() *configuration.Configuration
func (*DeployRequest) GetPlan ¶
func (x *DeployRequest) GetPlan() *schema.DeployPlan
func (*DeployRequest) ProtoMessage ¶
func (*DeployRequest) ProtoMessage()
func (*DeployRequest) ProtoReflect ¶
func (x *DeployRequest) ProtoReflect() protoreflect.Message
func (*DeployRequest) Reset ¶
func (x *DeployRequest) Reset()
func (*DeployRequest) String ¶
func (x *DeployRequest) String() string
type DeployResponse ¶
type DeployResponse struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // Deployment to follow // contains filtered or unexported fields }
func (*DeployResponse) Descriptor
deprecated
func (*DeployResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeployResponse.ProtoReflect.Descriptor instead.
func (*DeployResponse) GetId ¶
func (x *DeployResponse) GetId() string
func (*DeployResponse) ProtoMessage ¶
func (*DeployResponse) ProtoMessage()
func (*DeployResponse) ProtoReflect ¶
func (x *DeployResponse) ProtoReflect() protoreflect.Message
func (*DeployResponse) Reset ¶
func (x *DeployResponse) Reset()
func (*DeployResponse) String ¶
func (x *DeployResponse) String() string
type DeploymentStatusRequest ¶
type DeploymentStatusRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // Deployment to follow LogLevel int32 `protobuf:"varint,2,opt,name=log_level,json=logLevel,proto3" json:"log_level,omitempty"` // contains filtered or unexported fields }
func (*DeploymentStatusRequest) Descriptor
deprecated
func (*DeploymentStatusRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeploymentStatusRequest.ProtoReflect.Descriptor instead.
func (*DeploymentStatusRequest) GetId ¶
func (x *DeploymentStatusRequest) GetId() string
func (*DeploymentStatusRequest) GetLogLevel ¶
func (x *DeploymentStatusRequest) GetLogLevel() int32
func (*DeploymentStatusRequest) ProtoMessage ¶
func (*DeploymentStatusRequest) ProtoMessage()
func (*DeploymentStatusRequest) ProtoReflect ¶
func (x *DeploymentStatusRequest) ProtoReflect() protoreflect.Message
func (*DeploymentStatusRequest) Reset ¶
func (x *DeploymentStatusRequest) Reset()
func (*DeploymentStatusRequest) String ¶
func (x *DeploymentStatusRequest) String() string
type DeploymentStatusResponse ¶
type DeploymentStatusResponse struct { Event *orchestration.Event `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"` Log *protolog.Log `protobuf:"bytes,4,opt,name=log,proto3" json:"log,omitempty"` // contains filtered or unexported fields }
func (*DeploymentStatusResponse) Descriptor
deprecated
func (*DeploymentStatusResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeploymentStatusResponse.ProtoReflect.Descriptor instead.
func (*DeploymentStatusResponse) GetEvent ¶
func (x *DeploymentStatusResponse) GetEvent() *orchestration.Event
func (*DeploymentStatusResponse) GetLog ¶
func (x *DeploymentStatusResponse) GetLog() *protolog.Log
func (*DeploymentStatusResponse) ProtoMessage ¶
func (*DeploymentStatusResponse) ProtoMessage()
func (*DeploymentStatusResponse) ProtoReflect ¶
func (x *DeploymentStatusResponse) ProtoReflect() protoreflect.Message
func (*DeploymentStatusResponse) Reset ¶
func (x *DeploymentStatusResponse) Reset()
func (*DeploymentStatusResponse) String ¶
func (x *DeploymentStatusResponse) String() string
type GetOrchestratorVersionRequest ¶ added in v0.0.93
type GetOrchestratorVersionRequest struct { SkipCache bool `protobuf:"varint,1,opt,name=skip_cache,json=skipCache,proto3" json:"skip_cache,omitempty"` // contains filtered or unexported fields }
func (*GetOrchestratorVersionRequest) Descriptor
deprecated
added in
v0.0.93
func (*GetOrchestratorVersionRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetOrchestratorVersionRequest.ProtoReflect.Descriptor instead.
func (*GetOrchestratorVersionRequest) GetSkipCache ¶ added in v0.0.93
func (x *GetOrchestratorVersionRequest) GetSkipCache() bool
func (*GetOrchestratorVersionRequest) ProtoMessage ¶ added in v0.0.93
func (*GetOrchestratorVersionRequest) ProtoMessage()
func (*GetOrchestratorVersionRequest) ProtoReflect ¶ added in v0.0.93
func (x *GetOrchestratorVersionRequest) ProtoReflect() protoreflect.Message
func (*GetOrchestratorVersionRequest) Reset ¶ added in v0.0.93
func (x *GetOrchestratorVersionRequest) Reset()
func (*GetOrchestratorVersionRequest) String ¶ added in v0.0.93
func (x *GetOrchestratorVersionRequest) String() string
type GetOrchestratorVersionResponse ¶ added in v0.0.93
type GetOrchestratorVersionResponse struct { Current *schema.Workspace_BinaryDigest `protobuf:"bytes,1,opt,name=current,proto3" json:"current,omitempty"` Pinned []*schema.Workspace_BinaryDigest `protobuf:"bytes,2,rep,name=pinned,proto3" json:"pinned,omitempty"` // contains filtered or unexported fields }
func (*GetOrchestratorVersionResponse) Descriptor
deprecated
added in
v0.0.93
func (*GetOrchestratorVersionResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetOrchestratorVersionResponse.ProtoReflect.Descriptor instead.
func (*GetOrchestratorVersionResponse) GetCurrent ¶ added in v0.0.93
func (x *GetOrchestratorVersionResponse) GetCurrent() *schema.Workspace_BinaryDigest
func (*GetOrchestratorVersionResponse) GetPinned ¶ added in v0.0.93
func (x *GetOrchestratorVersionResponse) GetPinned() []*schema.Workspace_BinaryDigest
func (*GetOrchestratorVersionResponse) ProtoMessage ¶ added in v0.0.93
func (*GetOrchestratorVersionResponse) ProtoMessage()
func (*GetOrchestratorVersionResponse) ProtoReflect ¶ added in v0.0.93
func (x *GetOrchestratorVersionResponse) ProtoReflect() protoreflect.Message
func (*GetOrchestratorVersionResponse) Reset ¶ added in v0.0.93
func (x *GetOrchestratorVersionResponse) Reset()
func (*GetOrchestratorVersionResponse) String ¶ added in v0.0.93
func (x *GetOrchestratorVersionResponse) String() string
type OrchestrationServiceClient ¶
type OrchestrationServiceClient interface { Deploy(ctx context.Context, in *DeployRequest, opts ...grpc.CallOption) (*DeployResponse, error) DeploymentStatus(ctx context.Context, in *DeploymentStatusRequest, opts ...grpc.CallOption) (OrchestrationService_DeploymentStatusClient, error) GetOrchestratorVersion(ctx context.Context, in *GetOrchestratorVersionRequest, opts ...grpc.CallOption) (*GetOrchestratorVersionResponse, error) }
OrchestrationServiceClient is the client API for OrchestrationService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewOrchestrationServiceClient ¶
func NewOrchestrationServiceClient(cc grpc.ClientConnInterface) OrchestrationServiceClient
type OrchestrationServiceServer ¶
type OrchestrationServiceServer interface { Deploy(context.Context, *DeployRequest) (*DeployResponse, error) DeploymentStatus(*DeploymentStatusRequest, OrchestrationService_DeploymentStatusServer) error GetOrchestratorVersion(context.Context, *GetOrchestratorVersionRequest) (*GetOrchestratorVersionResponse, error) }
OrchestrationServiceServer is the server API for OrchestrationService service. All implementations should embed UnimplementedOrchestrationServiceServer for forward compatibility
type OrchestrationService_DeploymentStatusClient ¶
type OrchestrationService_DeploymentStatusClient interface { Recv() (*DeploymentStatusResponse, error) grpc.ClientStream }
type OrchestrationService_DeploymentStatusServer ¶
type OrchestrationService_DeploymentStatusServer interface { Send(*DeploymentStatusResponse) error grpc.ServerStream }
type UnimplementedOrchestrationServiceServer ¶
type UnimplementedOrchestrationServiceServer struct { }
UnimplementedOrchestrationServiceServer should be embedded to have forward compatible implementations.
func (UnimplementedOrchestrationServiceServer) Deploy ¶
func (UnimplementedOrchestrationServiceServer) Deploy(context.Context, *DeployRequest) (*DeployResponse, error)
func (UnimplementedOrchestrationServiceServer) DeploymentStatus ¶
func (UnimplementedOrchestrationServiceServer) DeploymentStatus(*DeploymentStatusRequest, OrchestrationService_DeploymentStatusServer) error
func (UnimplementedOrchestrationServiceServer) GetOrchestratorVersion ¶ added in v0.0.93
func (UnimplementedOrchestrationServiceServer) GetOrchestratorVersion(context.Context, *GetOrchestratorVersionRequest) (*GetOrchestratorVersionResponse, error)
type UnsafeOrchestrationServiceServer ¶
type UnsafeOrchestrationServiceServer interface {
// contains filtered or unexported methods
}
UnsafeOrchestrationServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to OrchestrationServiceServer will result in compilation errors.