server

package
v1.16.0 Latest Latest
Warning

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

 Go to latest Published: Jun 26, 2022 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_server_proto_server_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,
		},
	},
	Metadata: "server/proto/server.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 added in v1.1.0 

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

func (*Metadata) Descriptor deprecated added in v1.1.0 

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

Deprecated: Use Metadata.ProtoReflect.Descriptor instead.

func (*Metadata) GetName added in v1.1.0 

func (x *Metadata) GetName() string

func (*Metadata) ProtoMessage added in v1.1.0 

func (*Metadata) ProtoMessage()

func (*Metadata) ProtoReflect added in v1.1.0 

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

func (*Metadata) Reset added in v1.1.0 

func (x *Metadata) Reset()

func (*Metadata) String added in v1.1.0 

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 ServerProtoClient 

type ServerProtoClient interface {
	SendServer(ctx context.Context, in *ServerRequest, 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(*ServerRequest, 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 {
	Recv() (*ServerReply, error)
	grpc.ClientStream
}

type ServerProto_SendServerServer added in v1.11.0 

type ServerProto_SendServerServer interface {
	Send(*ServerReply) 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 added in v1.10.0 

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 added in v1.1.0 

func (x *ServerRequest) GetApiVersion() string

func (*ServerRequest) GetKind 

func (x *ServerRequest) GetKind() string

func (*ServerRequest) GetMetadata added in v1.1.0 

func (x *ServerRequest) GetMetadata() *Metadata

func (*ServerRequest) GetSpec added in v1.1.0 

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 added in v1.1.0 

type Spec struct {
	Task *Task `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	// contains filtered or unexported fields
}

func (*Spec) Descriptor deprecated added in v1.1.0 

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

Deprecated: Use Spec.ProtoReflect.Descriptor instead.

func (*Spec) GetTask added in v1.14.0 

func (x *Spec) GetTask() *Task

func (*Spec) ProtoMessage added in v1.1.0 

func (*Spec) ProtoMessage()

func (*Spec) ProtoReflect added in v1.1.0 

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

func (*Spec) Reset added in v1.1.0 

func (x *Spec) Reset()

func (*Spec) String added in v1.1.0 

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"`
	// contains filtered or unexported fields
}

func (*Task) Descriptor deprecated 

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

Deprecated: Use Task.ProtoReflect.Descriptor instead.

func (*Task) GetCommands added in v1.4.0 

func (x *Task) GetCommands() []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(*ServerRequest, 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.

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.