Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterServerProtoServer(s grpc.ServiceRegistrar, srv ServerProtoServer)
- type File
- type Metadata
- type Output
- type Param
- type ServerProtoClient
- type ServerProtoServer
- type ServerProto_SendServerClient
- type ServerProto_SendServerServer
- type ServerReply
- func (*ServerReply) Descriptor() ([]byte, []int)deprecated
- func (x *ServerReply) GetError() string
- func (x *ServerReply) GetOutput() *Output
- 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)deprecated
- 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
- type Task
- func (*Task) Descriptor() ([]byte, []int)deprecated
- func (x *Task) GetCommands() []string
- func (x *Task) GetFile() *File
- func (x *Task) GetLivelog() int64
- func (x *Task) GetName() string
- func (x *Task) GetParams() []*Param
- func (*Task) ProtoMessage()
- func (x *Task) ProtoReflect() protoreflect.Message
- func (x *Task) Reset()
- func (x *Task) String() string
- type UnimplementedServerProtoServer
- type UnsafeServerProtoServer
Constants ¶
const (
ServerProto_SendServer_FullMethodName = "/runner.ServerProto/SendServer"
)
Variables ¶
var File_runner_proto_runner_proto protoreflect.FileDescriptor
var ServerProto_ServiceDesc = grpc.ServiceDesc{ ServiceName: "runner.ServerProto", HandlerType: (*ServerProtoServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "SendServer", Handler: _ServerProto_SendServer_Handler, ServerStreams: true, ClientStreams: true, }, }, 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 File ¶ added in v1.20.0
type File struct { Content []byte `protobuf:"bytes,1,opt,name=content,proto3" json:"content,omitempty"` Gzip bool `protobuf:"varint,2,opt,name=gzip,proto3" json:"gzip,omitempty"` // contains filtered or unexported fields }
func (*File) Descriptor
deprecated
added in
v1.20.0
func (*File) GetContent ¶ added in v1.20.0
func (*File) ProtoMessage ¶ added in v1.20.0
func (*File) ProtoMessage()
func (*File) ProtoReflect ¶ added in v1.20.0
func (x *File) ProtoReflect() protoreflect.Message
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
deprecated
func (*Metadata) ProtoMessage ¶
func (*Metadata) ProtoMessage()
func (*Metadata) ProtoReflect ¶
func (x *Metadata) ProtoReflect() protoreflect.Message
type Output ¶ added in v1.12.0
type Output struct { Pos int64 `protobuf:"varint,1,opt,name=pos,proto3" json:"pos,omitempty"` Time int64 `protobuf:"varint,2,opt,name=time,proto3" json:"time,omitempty"` Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*Output) Descriptor
deprecated
added in
v1.12.0
func (*Output) GetMessage ¶ added in v1.12.0
func (*Output) ProtoMessage ¶ added in v1.12.0
func (*Output) ProtoMessage()
func (*Output) ProtoReflect ¶ added in v1.12.0
func (x *Output) ProtoReflect() protoreflect.Message
type Param ¶ added in v1.27.0
type Param struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*Param) Descriptor
deprecated
added in
v1.27.0
func (*Param) ProtoMessage ¶ added in v1.27.0
func (*Param) ProtoMessage()
func (*Param) ProtoReflect ¶ added in v1.27.0
func (x *Param) ProtoReflect() protoreflect.Message
type ServerProtoClient ¶
type ServerProtoClient interface {
SendServer(ctx context.Context, opts ...grpc.CallOption) (ServerProto_SendServerClient, 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(ServerProto_SendServerServer) error // contains filtered or unexported methods }
ServerProtoServer is the server API for ServerProto service. All implementations must embed UnimplementedServerProtoServer for forward compatibility
type ServerProto_SendServerClient ¶ added in v1.11.0
type ServerProto_SendServerClient interface { Send(*ServerRequest) error Recv() (*ServerReply, error) grpc.ClientStream }
type ServerProto_SendServerServer ¶ added in v1.11.0
type ServerProto_SendServerServer interface { Send(*ServerReply) error Recv() (*ServerRequest, error) grpc.ServerStream }
type ServerReply ¶
type ServerReply struct { Output *Output `protobuf:"bytes,1,opt,name=output,proto3" json:"output,omitempty"` Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` // contains filtered or unexported fields }
The response message.
func (*ServerReply) Descriptor
deprecated
func (*ServerReply) Descriptor() ([]byte, []int)
Deprecated: Use ServerReply.ProtoReflect.Descriptor instead.
func (*ServerReply) GetError ¶
func (x *ServerReply) GetError() string
func (*ServerReply) GetOutput ¶ added in v1.11.0
func (x *ServerReply) GetOutput() *Output
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
deprecated
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 { Task *Task `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"` // contains filtered or unexported fields }
func (*Spec) Descriptor
deprecated
func (*Spec) ProtoMessage ¶
func (*Spec) ProtoMessage()
func (*Spec) ProtoReflect ¶
func (x *Spec) ProtoReflect() protoreflect.Message
type Task ¶
type Task struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` File *File `protobuf:"bytes,2,opt,name=file,proto3" json:"file,omitempty"` Params []*Param `protobuf:"bytes,3,rep,name=params,proto3" json:"params,omitempty"` Commands []string `protobuf:"bytes,4,rep,name=commands,proto3" json:"commands,omitempty"` Livelog int64 `protobuf:"varint,5,opt,name=livelog,proto3" json:"livelog,omitempty"` // contains filtered or unexported fields }
func (*Task) Descriptor
deprecated
func (*Task) GetCommands ¶
func (*Task) GetLivelog ¶ added in v1.22.0
func (*Task) ProtoMessage ¶
func (*Task) ProtoMessage()
func (*Task) ProtoReflect ¶
func (x *Task) ProtoReflect() protoreflect.Message
type UnimplementedServerProtoServer ¶
type UnimplementedServerProtoServer struct { }
UnimplementedServerProtoServer must be embedded to have forward compatible implementations.
func (UnimplementedServerProtoServer) SendServer ¶
func (UnimplementedServerProtoServer) SendServer(ServerProto_SendServerServer) 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.