grpc

Documentation

Index

• Variables
• func RegisterQuMineServerServer(s *grpc.Server, srv QuMineServerServer)
• type LogStreamRequest
  • func (*LogStreamRequest) Descriptor() ([]byte, []int)
  • func (x *LogStreamRequest) GetLines() int32
  • func (*LogStreamRequest) ProtoMessage()
  • func (x *LogStreamRequest) ProtoReflect() protoreflect.Message
  • func (x *LogStreamRequest) Reset()
  • func (x *LogStreamRequest) String() string
• type LogStreamResponse
  • func (*LogStreamResponse) Descriptor() ([]byte, []int)
  • func (x *LogStreamResponse) GetLine() string
  • func (*LogStreamResponse) ProtoMessage()
  • func (x *LogStreamResponse) ProtoReflect() protoreflect.Message
  • func (x *LogStreamResponse) Reset()
  • func (x *LogStreamResponse) String() string
• type QuMineServerClient
  • func NewQuMineServerClient(cc grpc.ClientConnInterface) QuMineServerClient
• type QuMineServerServer
• type QuMineServer_SendCommandClient
• type QuMineServer_SendCommandServer
• type QuMineServer_StreamLogsClient
• type QuMineServer_StreamLogsServer
• type SendCommandRequest
  • func (*SendCommandRequest) Descriptor() ([]byte, []int)
  • func (x *SendCommandRequest) GetLine() string
  • func (*SendCommandRequest) ProtoMessage()
  • func (x *SendCommandRequest) ProtoReflect() protoreflect.Message
  • func (x *SendCommandRequest) Reset()
  • func (x *SendCommandRequest) String() string
• type SendCommandResponse
  • func (*SendCommandResponse) Descriptor() ([]byte, []int)
  • func (*SendCommandResponse) ProtoMessage()
  • func (x *SendCommandResponse) ProtoReflect() protoreflect.Message
  • func (x *SendCommandResponse) Reset()
  • func (x *SendCommandResponse) String() string
• type UnimplementedQuMineServerServer
  • func (*UnimplementedQuMineServerServer) SendCommand(*SendCommandRequest, QuMineServer_SendCommandServer) error
  • func (*UnimplementedQuMineServerServer) StreamLogs(*LogStreamRequest, QuMineServer_StreamLogsServer) error

Variables

var File_service_proto protoreflect.FileDescriptor

Functions

func RegisterQuMineServerServer

func RegisterQuMineServerServer(s *grpc.Server, srv QuMineServerServer)

Types

type LogStreamRequest

type LogStreamRequest struct {
	Lines int32 `protobuf:"varint,1,opt,name=lines,proto3" json:"lines,omitempty"`
	// contains filtered or unexported fields
}

func (*LogStreamRequest) Descriptor

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

Deprecated: Use LogStreamRequest.ProtoReflect.Descriptor instead.

func (*LogStreamRequest) GetLines

func (x *LogStreamRequest) GetLines() int32

func (*LogStreamRequest) ProtoMessage

func (*LogStreamRequest) ProtoMessage()

func (*LogStreamRequest) ProtoReflect

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

func (*LogStreamRequest) Reset

func (x *LogStreamRequest) Reset()

func (*LogStreamRequest) String

func (x *LogStreamRequest) String() string

type LogStreamResponse

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

func (*LogStreamResponse) Descriptor

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

Deprecated: Use LogStreamResponse.ProtoReflect.Descriptor instead.

func (*LogStreamResponse) GetLine

func (x *LogStreamResponse) GetLine() string

func (*LogStreamResponse) ProtoMessage

func (*LogStreamResponse) ProtoMessage()

func (*LogStreamResponse) ProtoReflect

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

func (*LogStreamResponse) Reset

func (x *LogStreamResponse) Reset()

func (*LogStreamResponse) String

func (x *LogStreamResponse) String() string

type QuMineServerClient

type QuMineServerClient interface {
	StreamLogs(ctx context.Context, in *LogStreamRequest, opts ...grpc.CallOption) (QuMineServer_StreamLogsClient, error)
	SendCommand(ctx context.Context, in *SendCommandRequest, opts ...grpc.CallOption) (QuMineServer_SendCommandClient, error)
}

QuMineServerClient is the client API for QuMineServer service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewQuMineServerClient

func NewQuMineServerClient(cc grpc.ClientConnInterface) QuMineServerClient

type QuMineServerServer

type QuMineServerServer interface {
	StreamLogs(*LogStreamRequest, QuMineServer_StreamLogsServer) error
	SendCommand(*SendCommandRequest, QuMineServer_SendCommandServer) error
}

QuMineServerServer is the server API for QuMineServer service.

type QuMineServer_SendCommandClient

type QuMineServer_SendCommandClient interface {
	Recv() (*SendCommandResponse, error)
	grpc.ClientStream
}

type QuMineServer_SendCommandServer

type QuMineServer_SendCommandServer interface {
	Send(*SendCommandResponse) error
	grpc.ServerStream
}

type QuMineServer_StreamLogsClient

type QuMineServer_StreamLogsClient interface {
	Recv() (*LogStreamResponse, error)
	grpc.ClientStream
}

type QuMineServer_StreamLogsServer

type QuMineServer_StreamLogsServer interface {
	Send(*LogStreamResponse) error
	grpc.ServerStream
}

type SendCommandRequest

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

func (*SendCommandRequest) Descriptor

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

Deprecated: Use SendCommandRequest.ProtoReflect.Descriptor instead.

func (*SendCommandRequest) GetLine

func (x *SendCommandRequest) GetLine() string

func (*SendCommandRequest) ProtoMessage

func (*SendCommandRequest) ProtoMessage()

func (*SendCommandRequest) ProtoReflect

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

func (*SendCommandRequest) Reset

func (x *SendCommandRequest) Reset()

func (*SendCommandRequest) String

func (x *SendCommandRequest) String() string

type SendCommandResponse

type SendCommandResponse struct {
	// contains filtered or unexported fields
}

func (*SendCommandResponse) Descriptor

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

Deprecated: Use SendCommandResponse.ProtoReflect.Descriptor instead.

func (*SendCommandResponse) ProtoMessage

func (*SendCommandResponse) ProtoMessage()

func (*SendCommandResponse) ProtoReflect

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

func (*SendCommandResponse) Reset

func (x *SendCommandResponse) Reset()

func (*SendCommandResponse) String

func (x *SendCommandResponse) String() string

type UnimplementedQuMineServerServer

type UnimplementedQuMineServerServer struct {
}

UnimplementedQuMineServerServer can be embedded to have forward compatible implementations.

func (*UnimplementedQuMineServerServer) SendCommand

func (*UnimplementedQuMineServerServer) SendCommand(*SendCommandRequest, QuMineServer_SendCommandServer) error

func (*UnimplementedQuMineServerServer) StreamLogs

func (*UnimplementedQuMineServerServer) StreamLogs(*LogStreamRequest, QuMineServer_StreamLogsServer) error