runner

Documentation

Index

• Variables
• func RegisterServerProtoServer(s grpc.ServiceRegistrar, srv ServerProtoServer)
• type Metadata
  • func (*Metadata) Descriptor() ([]byte, []int)
  • func (x *Metadata) GetName() string
  • func (*Metadata) ProtoMessage()
  • func (x *Metadata) ProtoReflect() protoreflect.Message
  • func (x *Metadata) Reset()
  • func (x *Metadata) String() string
• type ServerProtoClient
  • func NewServerProtoClient(cc grpc.ClientConnInterface) ServerProtoClient
• type ServerProtoServer
• type ServerReply
  • func (*ServerReply) Descriptor() ([]byte, []int)
  • func (x *ServerReply) GetError() string
  • func (x *ServerReply) GetResult() string
  • func (*ServerReply) ProtoMessage()
  • func (x *ServerReply) ProtoReflect() protoreflect.Message
  • func (x *ServerReply) Reset()
  • func (x *ServerReply) String() string
• type ServerRequest
  • func (*ServerRequest) Descriptor() ([]byte, []int)
  • func (x *ServerRequest) GetApiVersion() string
  • func (x *ServerRequest) GetKind() string
  • func (x *ServerRequest) GetMetadata() *Metadata
  • func (x *ServerRequest) GetSpec() *Spec
  • func (*ServerRequest) ProtoMessage()
  • func (x *ServerRequest) ProtoReflect() protoreflect.Message
  • func (x *ServerRequest) Reset()
  • func (x *ServerRequest) String() string
• type Spec
  • func (*Spec) Descriptor() ([]byte, []int)
  • func (x *Spec) GetTasks() []*Task
  • func (*Spec) ProtoMessage()
  • func (x *Spec) ProtoReflect() protoreflect.Message
  • func (x *Spec) Reset()
  • func (x *Spec) String() string
• type Task
  • func (*Task) Descriptor() ([]byte, []int)
  • func (x *Task) GetCommands() []string
  • func (x *Task) GetDepends() []string
  • func (x *Task) GetName() string
  • func (*Task) ProtoMessage()
  • func (x *Task) ProtoReflect() protoreflect.Message
  • func (x *Task) Reset()
  • func (x *Task) String() string
• type UnimplementedServerProtoServer
  • func (UnimplementedServerProtoServer) SendServer(context.Context, *ServerRequest) (*ServerReply, error)
• type UnsafeServerProtoServer

Variables

var File_runner_proto_runner_proto protoreflect.FileDescriptor

var ServerProto_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "runner.ServerProto",
	HandlerType: (*ServerProtoServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "SendServer",
			Handler:    _ServerProto_SendServer_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "runner/proto/runner.proto",
}

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

Functions

func RegisterServerProtoServer

func RegisterServerProtoServer(s grpc.ServiceRegistrar, srv ServerProtoServer)

Types

type Metadata

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

func (*Metadata) Descriptor

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

Deprecated: Use Metadata.ProtoReflect.Descriptor instead.

func (*Metadata) GetName

func (x *Metadata) GetName() string

func (*Metadata) ProtoMessage

func (*Metadata) ProtoMessage()

func (*Metadata) ProtoReflect

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

func (*Metadata) Reset

func (x *Metadata) Reset()

func (*Metadata) String

func (x *Metadata) String() string

type ServerProtoClient

type ServerProtoClient interface {
	SendServer(ctx context.Context, in *ServerRequest, opts ...grpc.CallOption) (*ServerReply, error)
}

ServerProtoClient is the client API for ServerProto 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 NewServerProtoClient

func NewServerProtoClient(cc grpc.ClientConnInterface) ServerProtoClient

type ServerProtoServer

type ServerProtoServer interface {
	SendServer(context.Context, *ServerRequest) (*ServerReply, error)
	// contains filtered or unexported methods
}

ServerProtoServer is the server API for ServerProto service. All implementations must embed UnimplementedServerProtoServer for forward compatibility

type ServerReply

type ServerReply struct {
	Result string `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	Error  string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

The response message.

func (*ServerReply) Descriptor

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

Deprecated: Use ServerReply.ProtoReflect.Descriptor instead.

func (*ServerReply) GetError

func (x *ServerReply) GetError() string

func (*ServerReply) GetResult

func (x *ServerReply) GetResult() string

func (*ServerReply) ProtoMessage

func (*ServerReply) ProtoMessage()

func (*ServerReply) ProtoReflect

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

func (*ServerReply) Reset

func (x *ServerReply) Reset()

func (*ServerReply) String

func (x *ServerReply) String() string

type ServerRequest

type ServerRequest struct {
	ApiVersion string    `protobuf:"bytes,1,opt,name=apiVersion,proto3" json:"apiVersion,omitempty"`
	Kind       string    `protobuf:"bytes,2,opt,name=kind,proto3" json:"kind,omitempty"`
	Metadata   *Metadata `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Spec       *Spec     `protobuf:"bytes,4,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

The request message.

func (*ServerRequest) Descriptor

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

Deprecated: Use ServerRequest.ProtoReflect.Descriptor instead.

func (*ServerRequest) GetApiVersion

func (x *ServerRequest) GetApiVersion() string

func (*ServerRequest) GetKind

func (x *ServerRequest) GetKind() string

func (*ServerRequest) GetMetadata

func (x *ServerRequest) GetMetadata() *Metadata

func (*ServerRequest) GetSpec

func (x *ServerRequest) GetSpec() *Spec

func (*ServerRequest) ProtoMessage

func (*ServerRequest) ProtoMessage()

func (*ServerRequest) ProtoReflect

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

func (*ServerRequest) Reset

func (x *ServerRequest) Reset()

func (*ServerRequest) String

func (x *ServerRequest) String() string

type Spec

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

func (*Spec) Descriptor

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

Deprecated: Use Spec.ProtoReflect.Descriptor instead.

func (*Spec) GetTasks

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

func (*Spec) ProtoMessage

func (*Spec) ProtoMessage()

func (*Spec) ProtoReflect

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

func (*Spec) Reset

func (x *Spec) Reset()

func (*Spec) String

func (x *Spec) String() string

type Task

type Task struct {
	Name     string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Commands []string `protobuf:"bytes,2,rep,name=commands,proto3" json:"commands,omitempty"`
	Depends  []string `protobuf:"bytes,3,rep,name=depends,proto3" json:"depends,omitempty"`
	// contains filtered or unexported fields
}

func (*Task) Descriptor

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

Deprecated: Use Task.ProtoReflect.Descriptor instead.

func (*Task) GetCommands

func (x *Task) GetCommands() []string

func (*Task) GetDepends

func (x *Task) GetDepends() []string

func (*Task) GetName

func (x *Task) GetName() string

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 UnimplementedServerProtoServer

type UnimplementedServerProtoServer struct {
}

UnimplementedServerProtoServer must be embedded to have forward compatible implementations.

func (UnimplementedServerProtoServer) SendServer

func (UnimplementedServerProtoServer) SendServer(context.Context, *ServerRequest) (*ServerReply, error)

type UnsafeServerProtoServer

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

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