rpc

Documentation

Overview

Package rpc is a generated protocol buffer package.

It is generated from these files:

rpc/rpc.proto

It has these top-level messages:

NewFunctionPodReq
NewFunctionPodResp

Index

• Variables
• func RegisterControllerServer(s *grpc.Server, srv ControllerServer)
• type ControllerClient
  • func NewControllerClient(cc *grpc.ClientConn) ControllerClient
• type ControllerServer
• type NewFunctionPodReq
  • func (*NewFunctionPodReq) Descriptor() ([]byte, []int)
  • func (m *NewFunctionPodReq) GetName() string
  • func (m *NewFunctionPodReq) Marshal() (dAtA []byte, err error)
  • func (m *NewFunctionPodReq) MarshalTo(dAtA []byte) (int, error)
  • func (*NewFunctionPodReq) ProtoMessage()
  • func (m *NewFunctionPodReq) Reset()
  • func (m *NewFunctionPodReq) Size() (n int)
  • func (m *NewFunctionPodReq) String() string
  • func (m *NewFunctionPodReq) Unmarshal(dAtA []byte) error
• type NewFunctionPodResp
  • func (*NewFunctionPodResp) Descriptor() ([]byte, []int)
  • func (m *NewFunctionPodResp) GetPodIP() string
  • func (m *NewFunctionPodResp) GetPodName() string
  • func (m *NewFunctionPodResp) GetVersion() int64
  • func (m *NewFunctionPodResp) Marshal() (dAtA []byte, err error)
  • func (m *NewFunctionPodResp) MarshalTo(dAtA []byte) (int, error)
  • func (*NewFunctionPodResp) ProtoMessage()
  • func (m *NewFunctionPodResp) Reset()
  • func (m *NewFunctionPodResp) Size() (n int)
  • func (m *NewFunctionPodResp) String() string
  • func (m *NewFunctionPodResp) Unmarshal(dAtA []byte) error

Variables

var (
	ErrInvalidLengthRpc = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRpc   = fmt.Errorf("proto: integer overflow")
)

Functions

func RegisterControllerServer

func RegisterControllerServer(s *grpc.Server, srv ControllerServer)

Types

type ControllerClient

type ControllerClient interface {
	NewFunctionPod(ctx context.Context, in *NewFunctionPodReq, opts ...grpc.CallOption) (*NewFunctionPodResp, error)
}

func NewControllerClient

func NewControllerClient(cc *grpc.ClientConn) ControllerClient

type ControllerServer

type ControllerServer interface {
	NewFunctionPod(context.Context, *NewFunctionPodReq) (*NewFunctionPodResp, error)
}

type NewFunctionPodReq

type NewFunctionPodReq struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
}

func (*NewFunctionPodReq) Descriptor

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

func (*NewFunctionPodReq) GetName

func (m *NewFunctionPodReq) GetName() string

func (*NewFunctionPodReq) Marshal

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

func (*NewFunctionPodReq) MarshalTo

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

func (*NewFunctionPodReq) ProtoMessage

func (*NewFunctionPodReq) ProtoMessage()

func (*NewFunctionPodReq) Reset

func (m *NewFunctionPodReq) Reset()

func (*NewFunctionPodReq) Size

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

func (*NewFunctionPodReq) String

func (m *NewFunctionPodReq) String() string

func (*NewFunctionPodReq) Unmarshal

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

type NewFunctionPodResp

type NewFunctionPodResp struct {
	PodName string `protobuf:"bytes,1,opt,name=pod_name,json=podName,proto3" json:"pod_name,omitempty"`
	PodIP   string `protobuf:"bytes,2,opt,name=podIP,proto3" json:"podIP,omitempty"`
	Version int64  `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
}

func (*NewFunctionPodResp) Descriptor

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

func (*NewFunctionPodResp) GetPodIP

func (m *NewFunctionPodResp) GetPodIP() string

func (*NewFunctionPodResp) GetPodName

func (m *NewFunctionPodResp) GetPodName() string

func (*NewFunctionPodResp) GetVersion

func (m *NewFunctionPodResp) GetVersion() int64

func (*NewFunctionPodResp) Marshal

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

func (*NewFunctionPodResp) MarshalTo

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

func (*NewFunctionPodResp) ProtoMessage

func (*NewFunctionPodResp) ProtoMessage()

func (*NewFunctionPodResp) Reset

func (m *NewFunctionPodResp) Reset()

func (*NewFunctionPodResp) Size

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

func (*NewFunctionPodResp) String

func (m *NewFunctionPodResp) String() string

func (*NewFunctionPodResp) Unmarshal

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