v1

Documentation

Index

• Variables
• func RegisterOperatorRPCServer(s grpc1.Server, srv OperatorRPCServer)
• type Operator
  • func (*Operator) Descriptor() ([]byte, []int)
  • func (m *Operator) Marshal() (dAtA []byte, err error)
  • func (m *Operator) MarshalTo(dAtA []byte) (int, error)
  • func (m *Operator) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*Operator) ProtoMessage()
  • func (m *Operator) Reset()
  • func (m *Operator) Size() (n int)
  • func (m *Operator) String() string
  • func (m *Operator) Unmarshal(dAtA []byte) error
  • func (m *Operator) XXX_DiscardUnknown()
  • func (m *Operator) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Operator) XXX_Merge(src proto.Message)
  • func (m *Operator) XXX_Size() int
  • func (m *Operator) XXX_Unmarshal(b []byte) error
• type OperatorRPCClient
  • func NewOperatorRPCClient(cc grpc1.ClientConn) OperatorRPCClient
• type OperatorRPCServer
• type OperatorRPC_StreamCheckClient
• type OperatorRPC_StreamCheckServer
• type UnimplementedOperatorRPCServer
  • func (*UnimplementedOperatorRPCServer) Check(ctx context.Context, req *emptypb.Empty) (*Operator, error)
  • func (*UnimplementedOperatorRPCServer) StreamCheck(req *emptypb.Empty, srv OperatorRPC_StreamCheckServer) error

Variables

var (
	ErrInvalidLengthService        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowService          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupService = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterOperatorRPCServer

func RegisterOperatorRPCServer(s grpc1.Server, srv OperatorRPCServer)

Types

type Operator

type Operator struct {
}

func (*Operator) Descriptor

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

func (*Operator) Marshal

func (m *Operator) Marshal() (dAtA []byte, err error)

func (*Operator) MarshalTo

func (m *Operator) MarshalTo(dAtA []byte) (int, error)

func (*Operator) MarshalToSizedBuffer

func (m *Operator) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Operator) ProtoMessage

func (*Operator) ProtoMessage()

func (*Operator) Reset

func (m *Operator) Reset()

func (*Operator) Size

func (m *Operator) Size() (n int)

func (*Operator) String

func (m *Operator) String() string

func (*Operator) Unmarshal

func (m *Operator) Unmarshal(dAtA []byte) error

func (*Operator) XXX_DiscardUnknown

func (m *Operator) XXX_DiscardUnknown()

func (*Operator) XXX_Marshal

func (m *Operator) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Operator) XXX_Merge

func (m *Operator) XXX_Merge(src proto.Message)

func (*Operator) XXX_Size

func (m *Operator) XXX_Size() int

func (*Operator) XXX_Unmarshal

func (m *Operator) XXX_Unmarshal(b []byte) error

type OperatorRPCClient

type OperatorRPCClient interface {
	// Check status of the operator
	Check(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*Operator, error)
	// StreamServiceLogs
	StreamCheck(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (OperatorRPC_StreamCheckClient, error)
}

OperatorRPCClient is the client API for OperatorRPC service.

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

func NewOperatorRPCClient

func NewOperatorRPCClient(cc grpc1.ClientConn) OperatorRPCClient

type OperatorRPCServer

type OperatorRPCServer interface {
	// Check status of the operator
	Check(context.Context, *emptypb.Empty) (*Operator, error)
	// StreamServiceLogs
	StreamCheck(*emptypb.Empty, OperatorRPC_StreamCheckServer) error
}

OperatorRPCServer is the server API for OperatorRPC service.

type OperatorRPC_StreamCheckClient

type OperatorRPC_StreamCheckClient interface {
	Recv() (*Operator, error)
	grpc.ClientStream
}

type OperatorRPC_StreamCheckServer

type OperatorRPC_StreamCheckServer interface {
	Send(*Operator) error
	grpc.ServerStream
}

type UnimplementedOperatorRPCServer

type UnimplementedOperatorRPCServer struct {
}

UnimplementedOperatorRPCServer can be embedded to have forward compatible implementations.

func (*UnimplementedOperatorRPCServer) Check

func (*UnimplementedOperatorRPCServer) Check(ctx context.Context, req *emptypb.Empty) (*Operator, error)

func (*UnimplementedOperatorRPCServer) StreamCheck

func (*UnimplementedOperatorRPCServer) StreamCheck(req *emptypb.Empty, srv OperatorRPC_StreamCheckServer) error