runner

package
v1.27.0 Latest Latest
Warning

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

Go to latest
Published: Sep 2, 2023 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source
const (
	ServerProto_SendServer_FullMethodName = "/runner.ServerProto/SendServer"
)

Variables

View Source
var File_runner_proto_runner_proto protoreflect.FileDescriptor
View Source
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) Descriptor() ([]byte, []int)

Deprecated: Use File.ProtoReflect.Descriptor instead.

func (*File) GetContent added in v1.20.0

func (x *File) GetContent() []byte

func (*File) GetGzip added in v1.20.0

func (x *File) GetGzip() bool

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

func (*File) Reset added in v1.20.0

func (x *File) Reset()

func (*File) String added in v1.20.0

func (x *File) String() string

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) 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 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) Descriptor() ([]byte, []int)

Deprecated: Use Output.ProtoReflect.Descriptor instead.

func (*Output) GetMessage added in v1.12.0

func (x *Output) GetMessage() string

func (*Output) GetPos added in v1.12.0

func (x *Output) GetPos() int64

func (*Output) GetTime added in v1.12.0

func (x *Output) GetTime() int64

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

func (*Output) Reset added in v1.12.0

func (x *Output) Reset()

func (*Output) String added in v1.12.0

func (x *Output) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Param.ProtoReflect.Descriptor instead.

func (*Param) GetName added in v1.27.0

func (x *Param) GetName() string

func (*Param) GetValue added in v1.27.0

func (x *Param) GetValue() string

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

func (*Param) Reset added in v1.27.0

func (x *Param) Reset()

func (*Param) String added in v1.27.0

func (x *Param) String() string

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.

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) Descriptor() ([]byte, []int)

Deprecated: Use Spec.ProtoReflect.Descriptor instead.

func (*Spec) GetTask added in v1.13.0

func (x *Spec) GetTask() *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"`
	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) Descriptor() ([]byte, []int)

Deprecated: Use Task.ProtoReflect.Descriptor instead.

func (*Task) GetCommands

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

func (*Task) GetFile added in v1.20.0

func (x *Task) GetFile() *File

func (*Task) GetLivelog added in v1.22.0

func (x *Task) GetLivelog() int64

func (*Task) GetName

func (x *Task) GetName() string

func (*Task) GetParams added in v1.27.0

func (x *Task) GetParams() []*Param

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

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL