rpc

Documentation

Index

• Variables
• func RegisterBootServer(s *grpc.Server, srv BootServer)
• type BootClient
  • func NewBootClient(cc *grpc.ClientConn) BootClient
• type BootServer
• type Boot_StopClient
• type Boot_StopServer
• type StopRequest
  • func (*StopRequest) Descriptor() ([]byte, []int)
  • func (m *StopRequest) GetForce() bool
  • func (m *StopRequest) Marshal() (dAtA []byte, err error)
  • func (m *StopRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *StopRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*StopRequest) ProtoMessage()
  • func (m *StopRequest) Reset()
  • func (m *StopRequest) Size() (n int)
  • func (m *StopRequest) String() string
  • func (m *StopRequest) Unmarshal(dAtA []byte) error
  • func (m *StopRequest) XXX_DiscardUnknown()
  • func (m *StopRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *StopRequest) XXX_Merge(src proto.Message)
  • func (m *StopRequest) XXX_Size() int
  • func (m *StopRequest) XXX_Unmarshal(b []byte) error
• type StopResponse
  • func (*StopResponse) Descriptor() ([]byte, []int)
  • func (m *StopResponse) GetErrno() int32
  • func (m *StopResponse) GetMsg() string
  • func (m *StopResponse) Marshal() (dAtA []byte, err error)
  • func (m *StopResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *StopResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*StopResponse) ProtoMessage()
  • func (m *StopResponse) Reset()
  • func (m *StopResponse) Size() (n int)
  • func (m *StopResponse) String() string
  • func (m *StopResponse) Unmarshal(dAtA []byte) error
  • func (m *StopResponse) XXX_DiscardUnknown()
  • func (m *StopResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *StopResponse) XXX_Merge(src proto.Message)
  • func (m *StopResponse) XXX_Size() int
  • func (m *StopResponse) XXX_Unmarshal(b []byte) error
• type UnimplementedBootServer
  • func (*UnimplementedBootServer) Stop(srv Boot_StopServer) error

Variables

var (
	ErrInvalidLengthBoot        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowBoot          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupBoot = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterBootServer

func RegisterBootServer(s *grpc.Server, srv BootServer)

Types

type BootClient

type BootClient interface {
	Stop(ctx context.Context, opts ...grpc.CallOption) (Boot_StopClient, error)
}

BootClient is the client API for Boot service.

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

func NewBootClient

func NewBootClient(cc *grpc.ClientConn) BootClient

type BootServer

type BootServer interface {
	Stop(Boot_StopServer) error
}

BootServer is the server API for Boot service.

type Boot_StopClient

type Boot_StopClient interface {
	Send(*StopRequest) error
	Recv() (*StopResponse, error)
	grpc.ClientStream
}

type Boot_StopServer

type Boot_StopServer interface {
	Send(*StopResponse) error
	Recv() (*StopRequest, error)
	grpc.ServerStream
}

type StopRequest

type StopRequest struct {
	Force                bool     `protobuf:"varint,1,opt,name=force,proto3" json:"force,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StopRequest) Descriptor

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

func (*StopRequest) GetForce

func (m *StopRequest) GetForce() bool

func (*StopRequest) Marshal

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

func (*StopRequest) MarshalTo

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

func (*StopRequest) MarshalToSizedBuffer

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

func (*StopRequest) ProtoMessage

func (*StopRequest) ProtoMessage()

func (*StopRequest) Reset

func (m *StopRequest) Reset()

func (*StopRequest) Size

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

func (*StopRequest) String

func (m *StopRequest) String() string

func (*StopRequest) Unmarshal

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

func (*StopRequest) XXX_DiscardUnknown

func (m *StopRequest) XXX_DiscardUnknown()

func (*StopRequest) XXX_Marshal

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

func (*StopRequest) XXX_Merge

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

func (*StopRequest) XXX_Size

func (m *StopRequest) XXX_Size() int

func (*StopRequest) XXX_Unmarshal

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

type StopResponse

type StopResponse struct {
	Msg                  string   `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
	Errno                int32    `protobuf:"varint,2,opt,name=errno,proto3" json:"errno,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StopResponse) Descriptor

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

func (*StopResponse) GetErrno

func (m *StopResponse) GetErrno() int32

func (*StopResponse) GetMsg

func (m *StopResponse) GetMsg() string

func (*StopResponse) Marshal

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

func (*StopResponse) MarshalTo

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

func (*StopResponse) MarshalToSizedBuffer

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

func (*StopResponse) ProtoMessage

func (*StopResponse) ProtoMessage()

func (*StopResponse) Reset

func (m *StopResponse) Reset()

func (*StopResponse) Size

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

func (*StopResponse) String

func (m *StopResponse) String() string

func (*StopResponse) Unmarshal

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

func (*StopResponse) XXX_DiscardUnknown

func (m *StopResponse) XXX_DiscardUnknown()

func (*StopResponse) XXX_Marshal

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

func (*StopResponse) XXX_Merge

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

func (*StopResponse) XXX_Size

func (m *StopResponse) XXX_Size() int

func (*StopResponse) XXX_Unmarshal

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

type UnimplementedBootServer

type UnimplementedBootServer struct {
}

UnimplementedBootServer can be embedded to have forward compatible implementations.

func (*UnimplementedBootServer) Stop

func (*UnimplementedBootServer) Stop(srv Boot_StopServer) error