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:
ActivateReq ActivateResp ListOfString ExecuteReq ExecuteResp MetricsReq MetricsResp
Index ¶
- Variables
- func RegisterSidecarServer(s *grpc.Server, srv SidecarServer)
- type ActivateReq
- func (*ActivateReq) Descriptor() ([]byte, []int)
- func (m *ActivateReq) GetCode() string
- func (m *ActivateReq) GetLink() string
- func (m *ActivateReq) Marshal() (dAtA []byte, err error)
- func (m *ActivateReq) MarshalTo(dAtA []byte) (int, error)
- func (*ActivateReq) ProtoMessage()
- func (m *ActivateReq) Reset()
- func (m *ActivateReq) Size() (n int)
- func (m *ActivateReq) String() string
- func (m *ActivateReq) Unmarshal(dAtA []byte) error
- type ActivateResp
- func (*ActivateResp) Descriptor() ([]byte, []int)
- func (m *ActivateResp) Marshal() (dAtA []byte, err error)
- func (m *ActivateResp) MarshalTo(dAtA []byte) (int, error)
- func (*ActivateResp) ProtoMessage()
- func (m *ActivateResp) Reset()
- func (m *ActivateResp) Size() (n int)
- func (m *ActivateResp) String() string
- func (m *ActivateResp) Unmarshal(dAtA []byte) error
- type ExecuteReq
- func (*ExecuteReq) Descriptor() ([]byte, []int)
- func (m *ExecuteReq) GetBody() []byte
- func (m *ExecuteReq) GetHeader() map[string]*ListOfString
- func (m *ExecuteReq) GetMethod() string
- func (m *ExecuteReq) GetName() string
- func (m *ExecuteReq) GetPath() string
- func (m *ExecuteReq) GetQuery() map[string]*ListOfString
- func (m *ExecuteReq) Marshal() (dAtA []byte, err error)
- func (m *ExecuteReq) MarshalTo(dAtA []byte) (int, error)
- func (*ExecuteReq) ProtoMessage()
- func (m *ExecuteReq) Reset()
- func (m *ExecuteReq) Size() (n int)
- func (m *ExecuteReq) String() string
- func (m *ExecuteReq) Unmarshal(dAtA []byte) error
- type ExecuteResp
- func (*ExecuteResp) Descriptor() ([]byte, []int)
- func (m *ExecuteResp) GetBody() []byte
- func (m *ExecuteResp) GetHeader() map[string]*ListOfString
- func (m *ExecuteResp) GetStatus() string
- func (m *ExecuteResp) GetStatusCode() int32
- func (m *ExecuteResp) Marshal() (dAtA []byte, err error)
- func (m *ExecuteResp) MarshalTo(dAtA []byte) (int, error)
- func (*ExecuteResp) ProtoMessage()
- func (m *ExecuteResp) Reset()
- func (m *ExecuteResp) Size() (n int)
- func (m *ExecuteResp) String() string
- func (m *ExecuteResp) Unmarshal(dAtA []byte) error
- type ListOfString
- func (*ListOfString) Descriptor() ([]byte, []int)
- func (m *ListOfString) GetValue() []string
- func (m *ListOfString) Marshal() (dAtA []byte, err error)
- func (m *ListOfString) MarshalTo(dAtA []byte) (int, error)
- func (*ListOfString) ProtoMessage()
- func (m *ListOfString) Reset()
- func (m *ListOfString) Size() (n int)
- func (m *ListOfString) String() string
- func (m *ListOfString) Unmarshal(dAtA []byte) error
- type MetricsReq
- func (*MetricsReq) Descriptor() ([]byte, []int)
- func (m *MetricsReq) GetFromController() bool
- func (m *MetricsReq) Marshal() (dAtA []byte, err error)
- func (m *MetricsReq) MarshalTo(dAtA []byte) (int, error)
- func (*MetricsReq) ProtoMessage()
- func (m *MetricsReq) Reset()
- func (m *MetricsReq) Size() (n int)
- func (m *MetricsReq) String() string
- func (m *MetricsReq) Unmarshal(dAtA []byte) error
- type MetricsResp
- func (*MetricsResp) Descriptor() ([]byte, []int)
- func (m *MetricsResp) GetFreeMem() float32
- func (m *MetricsResp) GetLastPing() float64
- func (m *MetricsResp) GetLastReq() float64
- func (m *MetricsResp) GetLoadAvg() []float32
- func (m *MetricsResp) GetTerminate() bool
- func (m *MetricsResp) Marshal() (dAtA []byte, err error)
- func (m *MetricsResp) MarshalTo(dAtA []byte) (int, error)
- func (*MetricsResp) ProtoMessage()
- func (m *MetricsResp) Reset()
- func (m *MetricsResp) Size() (n int)
- func (m *MetricsResp) String() string
- func (m *MetricsResp) Unmarshal(dAtA []byte) error
- type SidecarClient
- type SidecarServer
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthRpc = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowRpc = fmt.Errorf("proto: integer overflow") )
Functions ¶
func RegisterSidecarServer ¶
func RegisterSidecarServer(s *grpc.Server, srv SidecarServer)
Types ¶
type ActivateReq ¶
type ActivateReq struct { Link string `protobuf:"bytes,1,opt,name=link,proto3" json:"link,omitempty"` Code string `protobuf:"bytes,2,opt,name=code,proto3" json:"code,omitempty"` }
func (*ActivateReq) Descriptor ¶
func (*ActivateReq) Descriptor() ([]byte, []int)
func (*ActivateReq) GetCode ¶
func (m *ActivateReq) GetCode() string
func (*ActivateReq) GetLink ¶
func (m *ActivateReq) GetLink() string
func (*ActivateReq) Marshal ¶
func (m *ActivateReq) Marshal() (dAtA []byte, err error)
func (*ActivateReq) ProtoMessage ¶
func (*ActivateReq) ProtoMessage()
func (*ActivateReq) Reset ¶
func (m *ActivateReq) Reset()
func (*ActivateReq) Size ¶
func (m *ActivateReq) Size() (n int)
func (*ActivateReq) String ¶
func (m *ActivateReq) String() string
func (*ActivateReq) Unmarshal ¶
func (m *ActivateReq) Unmarshal(dAtA []byte) error
type ActivateResp ¶
type ActivateResp struct { }
func (*ActivateResp) Descriptor ¶
func (*ActivateResp) Descriptor() ([]byte, []int)
func (*ActivateResp) Marshal ¶
func (m *ActivateResp) Marshal() (dAtA []byte, err error)
func (*ActivateResp) ProtoMessage ¶
func (*ActivateResp) ProtoMessage()
func (*ActivateResp) Reset ¶
func (m *ActivateResp) Reset()
func (*ActivateResp) Size ¶
func (m *ActivateResp) Size() (n int)
func (*ActivateResp) String ¶
func (m *ActivateResp) String() string
func (*ActivateResp) Unmarshal ¶
func (m *ActivateResp) Unmarshal(dAtA []byte) error
type ExecuteReq ¶
type ExecuteReq struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Method string `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"` Path string `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"` Query map[string]*ListOfString `` /* 137-byte string literal not displayed */ Header map[string]*ListOfString `` /* 139-byte string literal not displayed */ Body []byte `protobuf:"bytes,6,opt,name=body,proto3" json:"body,omitempty"` }
func (*ExecuteReq) Descriptor ¶
func (*ExecuteReq) Descriptor() ([]byte, []int)
func (*ExecuteReq) GetBody ¶
func (m *ExecuteReq) GetBody() []byte
func (*ExecuteReq) GetHeader ¶
func (m *ExecuteReq) GetHeader() map[string]*ListOfString
func (*ExecuteReq) GetMethod ¶
func (m *ExecuteReq) GetMethod() string
func (*ExecuteReq) GetName ¶
func (m *ExecuteReq) GetName() string
func (*ExecuteReq) GetPath ¶
func (m *ExecuteReq) GetPath() string
func (*ExecuteReq) GetQuery ¶
func (m *ExecuteReq) GetQuery() map[string]*ListOfString
func (*ExecuteReq) Marshal ¶
func (m *ExecuteReq) Marshal() (dAtA []byte, err error)
func (*ExecuteReq) ProtoMessage ¶
func (*ExecuteReq) ProtoMessage()
func (*ExecuteReq) Reset ¶
func (m *ExecuteReq) Reset()
func (*ExecuteReq) Size ¶
func (m *ExecuteReq) Size() (n int)
func (*ExecuteReq) String ¶
func (m *ExecuteReq) String() string
func (*ExecuteReq) Unmarshal ¶
func (m *ExecuteReq) Unmarshal(dAtA []byte) error
type ExecuteResp ¶
type ExecuteResp struct { StatusCode int32 `protobuf:"varint,1,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"` Status string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"` Header map[string]*ListOfString `` /* 139-byte string literal not displayed */ Body []byte `protobuf:"bytes,4,opt,name=body,proto3" json:"body,omitempty"` }
func (*ExecuteResp) Descriptor ¶
func (*ExecuteResp) Descriptor() ([]byte, []int)
func (*ExecuteResp) GetBody ¶
func (m *ExecuteResp) GetBody() []byte
func (*ExecuteResp) GetHeader ¶
func (m *ExecuteResp) GetHeader() map[string]*ListOfString
func (*ExecuteResp) GetStatus ¶
func (m *ExecuteResp) GetStatus() string
func (*ExecuteResp) GetStatusCode ¶
func (m *ExecuteResp) GetStatusCode() int32
func (*ExecuteResp) Marshal ¶
func (m *ExecuteResp) Marshal() (dAtA []byte, err error)
func (*ExecuteResp) ProtoMessage ¶
func (*ExecuteResp) ProtoMessage()
func (*ExecuteResp) Reset ¶
func (m *ExecuteResp) Reset()
func (*ExecuteResp) Size ¶
func (m *ExecuteResp) Size() (n int)
func (*ExecuteResp) String ¶
func (m *ExecuteResp) String() string
func (*ExecuteResp) Unmarshal ¶
func (m *ExecuteResp) Unmarshal(dAtA []byte) error
type ListOfString ¶
type ListOfString struct {
Value []string `protobuf:"bytes,1,rep,name=value" json:"value,omitempty"`
}
func (*ListOfString) Descriptor ¶
func (*ListOfString) Descriptor() ([]byte, []int)
func (*ListOfString) GetValue ¶
func (m *ListOfString) GetValue() []string
func (*ListOfString) Marshal ¶
func (m *ListOfString) Marshal() (dAtA []byte, err error)
func (*ListOfString) ProtoMessage ¶
func (*ListOfString) ProtoMessage()
func (*ListOfString) Reset ¶
func (m *ListOfString) Reset()
func (*ListOfString) Size ¶
func (m *ListOfString) Size() (n int)
func (*ListOfString) String ¶
func (m *ListOfString) String() string
func (*ListOfString) Unmarshal ¶
func (m *ListOfString) Unmarshal(dAtA []byte) error
type MetricsReq ¶
type MetricsReq struct {
FromController bool `protobuf:"varint,1,opt,name=from_controller,json=fromController,proto3" json:"from_controller,omitempty"`
}
func (*MetricsReq) Descriptor ¶
func (*MetricsReq) Descriptor() ([]byte, []int)
func (*MetricsReq) GetFromController ¶
func (m *MetricsReq) GetFromController() bool
func (*MetricsReq) Marshal ¶
func (m *MetricsReq) Marshal() (dAtA []byte, err error)
func (*MetricsReq) ProtoMessage ¶
func (*MetricsReq) ProtoMessage()
func (*MetricsReq) Reset ¶
func (m *MetricsReq) Reset()
func (*MetricsReq) Size ¶
func (m *MetricsReq) Size() (n int)
func (*MetricsReq) String ¶
func (m *MetricsReq) String() string
func (*MetricsReq) Unmarshal ¶
func (m *MetricsReq) Unmarshal(dAtA []byte) error
type MetricsResp ¶
type MetricsResp struct { LoadAvg []float32 `protobuf:"fixed32,1,rep,packed,name=load_avg,json=loadAvg" json:"load_avg,omitempty"` FreeMem float32 `protobuf:"fixed32,2,opt,name=free_mem,json=freeMem,proto3" json:"free_mem,omitempty"` LastReq float64 `protobuf:"fixed64,3,opt,name=last_req,json=lastReq,proto3" json:"last_req,omitempty"` LastPing float64 `protobuf:"fixed64,4,opt,name=last_ping,json=lastPing,proto3" json:"last_ping,omitempty"` Terminate bool `protobuf:"varint,5,opt,name=terminate,proto3" json:"terminate,omitempty"` }
func (*MetricsResp) Descriptor ¶
func (*MetricsResp) Descriptor() ([]byte, []int)
func (*MetricsResp) GetFreeMem ¶
func (m *MetricsResp) GetFreeMem() float32
func (*MetricsResp) GetLastPing ¶
func (m *MetricsResp) GetLastPing() float64
func (*MetricsResp) GetLastReq ¶
func (m *MetricsResp) GetLastReq() float64
func (*MetricsResp) GetLoadAvg ¶
func (m *MetricsResp) GetLoadAvg() []float32
func (*MetricsResp) GetTerminate ¶
func (m *MetricsResp) GetTerminate() bool
func (*MetricsResp) Marshal ¶
func (m *MetricsResp) Marshal() (dAtA []byte, err error)
func (*MetricsResp) ProtoMessage ¶
func (*MetricsResp) ProtoMessage()
func (*MetricsResp) Reset ¶
func (m *MetricsResp) Reset()
func (*MetricsResp) Size ¶
func (m *MetricsResp) Size() (n int)
func (*MetricsResp) String ¶
func (m *MetricsResp) String() string
func (*MetricsResp) Unmarshal ¶
func (m *MetricsResp) Unmarshal(dAtA []byte) error
type SidecarClient ¶
type SidecarClient interface { Activate(ctx context.Context, in *ActivateReq, opts ...grpc.CallOption) (*ActivateResp, error) Execute(ctx context.Context, in *ExecuteReq, opts ...grpc.CallOption) (*ExecuteResp, error) Metrics(ctx context.Context, in *MetricsReq, opts ...grpc.CallOption) (*MetricsResp, error) }
func NewSidecarClient ¶
func NewSidecarClient(cc *grpc.ClientConn) SidecarClient
type SidecarServer ¶
type SidecarServer interface { Activate(context.Context, *ActivateReq) (*ActivateResp, error) Execute(context.Context, *ExecuteReq) (*ExecuteResp, error) Metrics(context.Context, *MetricsReq) (*MetricsResp, error) }
Click to show internal directories.
Click to hide internal directories.