taskmasterpb

package
v0.0.0-...-c996816 Latest Latest
Warning

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

 Go to latest Published: Jul 3, 2023 License: ISC Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Status_name = map[int32]string{
		0: "UNKNOWN",
		1: "UNSTARTED",
		2: "STARTING",
		3: "RUNNING",
		4: "STOPPING",
		5: "STOPPED",
		6: "ERRORED",
	}
	Status_value = map[string]int32{
		"UNKNOWN":   0,
		"UNSTARTED": 1,
		"STARTING":  2,
		"RUNNING":   3,
		"STOPPING":  4,
		"STOPPED":   5,
		"ERRORED":   6,
	}
)

Enum value maps for Status.

View Source 
var File_api_taskmasterpb_taskmaster_proto protoreflect.FileDescriptor
View Source 
var Taskmaster_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "Taskmaster",
	HandlerType: (*TaskmasterServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Reload",
			Handler:    _Taskmaster_Reload_Handler,
		},
		{
			MethodName: "Stop",
			Handler:    _Taskmaster_Stop_Handler,
		},
		{
			MethodName: "ListTasks",
			Handler:    _Taskmaster_ListTasks_Handler,
		},
		{
			MethodName: "GetTask",
			Handler:    _Taskmaster_GetTask_Handler,
		},
		{
			MethodName: "StartTask",
			Handler:    _Taskmaster_StartTask_Handler,
		},
		{
			MethodName: "StopTask",
			Handler:    _Taskmaster_StopTask_Handler,
		},
		{
			MethodName: "RestartTask",
			Handler:    _Taskmaster_RestartTask_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api/taskmasterpb/taskmaster.proto",
}

Taskmaster_ServiceDesc is the grpc.ServiceDesc for Taskmaster service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterTaskmasterServer 

func RegisterTaskmasterServer(s grpc.ServiceRegistrar, srv TaskmasterServer)

Types

type Status 

type Status int32
const (
	Status_UNKNOWN   Status = 0
	Status_UNSTARTED Status = 1
	Status_STARTING  Status = 2
	Status_RUNNING   Status = 3
	Status_STOPPING  Status = 4
	Status_STOPPED   Status = 5
	Status_ERRORED   Status = 6
)

func (Status) Descriptor 

func (Status) Descriptor() protoreflect.EnumDescriptor

func (Status) Enum 

func (x Status) Enum() *Status

func (Status) EnumDescriptor deprecated 

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

Deprecated: Use Status.Descriptor instead.

func (Status) Number 

func (x Status) Number() protoreflect.EnumNumber

func (Status) String 

func (x Status) String() string

func (Status) Type 

func (Status) Type() protoreflect.EnumType

type Task 

type Task struct {
	Name     string               `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Status   Status               `protobuf:"varint,2,opt,name=status,proto3,enum=Status" json:"status,omitempty"`
	Pid      *int32               `protobuf:"varint,3,opt,name=pid,proto3,oneof" json:"pid,omitempty"`
	Exitcode *int32               `protobuf:"varint,4,opt,name=exitcode,proto3,oneof" json:"exitcode,omitempty"`
	Uptime   *durationpb.Duration `protobuf:"bytes,5,opt,name=uptime,proto3,oneof" json:"uptime,omitempty"`
	// contains filtered or unexported fields
}

func (*Task) Descriptor deprecated 

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

Deprecated: Use Task.ProtoReflect.Descriptor instead.

func (*Task) GetExitcode 

func (x *Task) GetExitcode() int32

func (*Task) GetName 

func (x *Task) GetName() string

func (*Task) GetPid 

func (x *Task) GetPid() int32

func (*Task) GetStatus 

func (x *Task) GetStatus() Status

func (*Task) GetUptime 

func (x *Task) GetUptime() *durationpb.Duration

func (*Task) ProtoMessage 

func (*Task) ProtoMessage()

func (*Task) ProtoReflect 

func (x *Task) ProtoReflect() protoreflect.Message

func (*Task) Reset 

func (x *Task) Reset()

func (*Task) String 

func (x *Task) String() string

type TaskIdentifier 

type TaskIdentifier struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskIdentifier) Descriptor deprecated 

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

Deprecated: Use TaskIdentifier.ProtoReflect.Descriptor instead.

func (*TaskIdentifier) GetName 

func (x *TaskIdentifier) GetName() string

func (*TaskIdentifier) ProtoMessage 

func (*TaskIdentifier) ProtoMessage()

func (*TaskIdentifier) ProtoReflect 

func (x *TaskIdentifier) ProtoReflect() protoreflect.Message

func (*TaskIdentifier) Reset 

func (x *TaskIdentifier) Reset()

func (*TaskIdentifier) String 

func (x *TaskIdentifier) String() string

type TaskmasterClient 

type TaskmasterClient interface {
	Reload(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Stop(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ListTasks(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*TasksList, error)
	GetTask(ctx context.Context, in *TaskIdentifier, opts ...grpc.CallOption) (*Task, error)
	StartTask(ctx context.Context, in *TaskIdentifier, opts ...grpc.CallOption) (*emptypb.Empty, error)
	StopTask(ctx context.Context, in *TaskIdentifier, opts ...grpc.CallOption) (*emptypb.Empty, error)
	RestartTask(ctx context.Context, in *TaskIdentifier, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

TaskmasterClient is the client API for Taskmaster 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 NewTaskmasterClient 

func NewTaskmasterClient(cc grpc.ClientConnInterface) TaskmasterClient

type TaskmasterServer 

type TaskmasterServer interface {
	Reload(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	Stop(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	ListTasks(context.Context, *emptypb.Empty) (*TasksList, error)
	GetTask(context.Context, *TaskIdentifier) (*Task, error)
	StartTask(context.Context, *TaskIdentifier) (*emptypb.Empty, error)
	StopTask(context.Context, *TaskIdentifier) (*emptypb.Empty, error)
	RestartTask(context.Context, *TaskIdentifier) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

TaskmasterServer is the server API for Taskmaster service. All implementations must embed UnimplementedTaskmasterServer for forward compatibility

type TasksList 

type TasksList struct {
	Tasks []*Task `protobuf:"bytes,1,rep,name=Tasks,proto3" json:"Tasks,omitempty"`
	// contains filtered or unexported fields
}

func (*TasksList) Descriptor deprecated 

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

Deprecated: Use TasksList.ProtoReflect.Descriptor instead.

func (*TasksList) GetTasks 

func (x *TasksList) GetTasks() []*Task

func (*TasksList) ProtoMessage 

func (*TasksList) ProtoMessage()

func (*TasksList) ProtoReflect 

func (x *TasksList) ProtoReflect() protoreflect.Message

func (*TasksList) Reset 

func (x *TasksList) Reset()

func (*TasksList) String 

func (x *TasksList) String() string

type UnimplementedTaskmasterServer 

type UnimplementedTaskmasterServer struct {
}

UnimplementedTaskmasterServer must be embedded to have forward compatible implementations.

func (UnimplementedTaskmasterServer) GetTask 

func (UnimplementedTaskmasterServer) GetTask(context.Context, *TaskIdentifier) (*Task, error)

func (UnimplementedTaskmasterServer) ListTasks 

func (UnimplementedTaskmasterServer) ListTasks(context.Context, *emptypb.Empty) (*TasksList, error)

func (UnimplementedTaskmasterServer) Reload 

func (UnimplementedTaskmasterServer) Reload(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

func (UnimplementedTaskmasterServer) RestartTask 

func (UnimplementedTaskmasterServer) RestartTask(context.Context, *TaskIdentifier) (*emptypb.Empty, error)

func (UnimplementedTaskmasterServer) StartTask 

func (UnimplementedTaskmasterServer) StartTask(context.Context, *TaskIdentifier) (*emptypb.Empty, error)

func (UnimplementedTaskmasterServer) Stop 

func (UnimplementedTaskmasterServer) Stop(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

func (UnimplementedTaskmasterServer) StopTask 

func (UnimplementedTaskmasterServer) StopTask(context.Context, *TaskIdentifier) (*emptypb.Empty, error)

type UnsafeTaskmasterServer 

type UnsafeTaskmasterServer interface {
	// contains filtered or unexported methods
}

UnsafeTaskmasterServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TaskmasterServer will result in compilation errors.

Source Files

View all Source files

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.