rpc

package
v0.0.0-...-acdf8ed Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 23, 2019 License: MIT Imports: 6 Imported by: 0

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

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 (m *ActivateReq) GetLink() string

func (*ActivateReq) Marshal

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

func (*ActivateReq) MarshalTo

func (m *ActivateReq) MarshalTo(dAtA []byte) (int, 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) MarshalTo

func (m *ActivateResp) MarshalTo(dAtA []byte) (int, 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) MarshalTo

func (m *ExecuteReq) MarshalTo(dAtA []byte) (int, 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) MarshalTo

func (m *ExecuteResp) MarshalTo(dAtA []byte) (int, 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) MarshalTo

func (m *ListOfString) MarshalTo(dAtA []byte) (int, 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) MarshalTo

func (m *MetricsReq) MarshalTo(dAtA []byte) (int, 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) MarshalTo

func (m *MetricsResp) MarshalTo(dAtA []byte) (int, 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)
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL