rpc

package
v0.4.4 Latest Latest
Warning

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

 Go to latest Published: Sep 21, 2018 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Overview

Package rpc is a generated protocol buffer package.

It is generated from these files: 

m3nsch.proto

It has these top-level messages: 

StatusRequest
StatusResponse
InitRequest
InitResponse
ModifyRequest
ModifyResponse
StartRequest
StartResponse
StopRequest
StopResponse
Workload

Index

Constants

This section is empty.

Variables

View Source 
var Status_name = map[int32]string{
	0: "UNKNOWN",
	1: "UNINITIALIZED",
	2: "INITIALIZED",
	3: "RUNNING",
}
View Source 
var Status_value = map[string]int32{
	"UNKNOWN":       0,
	"UNINITIALIZED": 1,
	"INITIALIZED":   2,
	"RUNNING":       3,
}

Functions

func RegisterMenschServer 

func RegisterMenschServer(s *grpc.Server, srv MenschServer)

Types

type InitRequest 

type InitRequest struct {
	Token      string    `protobuf:"bytes,1,opt,name=token" json:"token,omitempty"`
	Workload   *Workload `protobuf:"bytes,2,opt,name=workload" json:"workload,omitempty"`
	Force      bool      `protobuf:"varint,3,opt,name=force" json:"force,omitempty"`
	TargetZone string    `protobuf:"bytes,4,opt,name=targetZone" json:"targetZone,omitempty"`
	TargetEnv  string    `protobuf:"bytes,5,opt,name=targetEnv" json:"targetEnv,omitempty"`
}

func (*InitRequest) Descriptor 

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

func (*InitRequest) GetForce 

func (m *InitRequest) GetForce() bool

func (*InitRequest) GetTargetEnv 

func (m *InitRequest) GetTargetEnv() string

func (*InitRequest) GetTargetZone 

func (m *InitRequest) GetTargetZone() string

func (*InitRequest) GetToken 

func (m *InitRequest) GetToken() string

func (*InitRequest) GetWorkload 

func (m *InitRequest) GetWorkload() *Workload

func (*InitRequest) ProtoMessage 

func (*InitRequest) ProtoMessage()

func (*InitRequest) Reset 

func (m *InitRequest) Reset()

func (*InitRequest) String 

func (m *InitRequest) String() string

type InitResponse 

type InitResponse struct {
}

func (*InitResponse) Descriptor 

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

func (*InitResponse) ProtoMessage 

func (*InitResponse) ProtoMessage()

func (*InitResponse) Reset 

func (m *InitResponse) Reset()

func (*InitResponse) String 

func (m *InitResponse) String() string

type MenschClient 

type MenschClient interface {
	Status(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusResponse, error)
	Init(ctx context.Context, in *InitRequest, opts ...grpc.CallOption) (*InitResponse, error)
	Start(ctx context.Context, in *StartRequest, opts ...grpc.CallOption) (*StartResponse, error)
	Stop(ctx context.Context, in *StopRequest, opts ...grpc.CallOption) (*StopResponse, error)
	Modify(ctx context.Context, in *ModifyRequest, opts ...grpc.CallOption) (*ModifyResponse, error)
}

func NewMenschClient 

func NewMenschClient(cc *grpc.ClientConn) MenschClient

type MenschServer 

type MenschServer interface {
	Status(context.Context, *StatusRequest) (*StatusResponse, error)
	Init(context.Context, *InitRequest) (*InitResponse, error)
	Start(context.Context, *StartRequest) (*StartResponse, error)
	Stop(context.Context, *StopRequest) (*StopResponse, error)
	Modify(context.Context, *ModifyRequest) (*ModifyResponse, error)
}

type MockMenschClient 

type MockMenschClient struct {
	// contains filtered or unexported fields
}

Mock of MenschClient interface

func NewMockMenschClient 

func NewMockMenschClient(ctrl *gomock.Controller) *MockMenschClient

func (*MockMenschClient) EXPECT 

func (_m *MockMenschClient) EXPECT() *_MockMenschClientRecorder

func (*MockMenschClient) Init 

func (_m *MockMenschClient) Init(ctx context.Context, in *InitRequest, opts ...grpc.CallOption) (*InitResponse, error)

func (*MockMenschClient) Modify 

func (_m *MockMenschClient) Modify(ctx context.Context, in *ModifyRequest, opts ...grpc.CallOption) (*ModifyResponse, error)

func (*MockMenschClient) Start 

func (_m *MockMenschClient) Start(ctx context.Context, in *StartRequest, opts ...grpc.CallOption) (*StartResponse, error)

func (*MockMenschClient) Status 

func (_m *MockMenschClient) Status(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusResponse, error)

func (*MockMenschClient) Stop 

func (_m *MockMenschClient) Stop(ctx context.Context, in *StopRequest, opts ...grpc.CallOption) (*StopResponse, error)

type MockMenschServer 

type MockMenschServer struct {
	// contains filtered or unexported fields
}

Mock of MenschServer interface

func NewMockMenschServer 

func NewMockMenschServer(ctrl *gomock.Controller) *MockMenschServer

func (*MockMenschServer) EXPECT 

func (_m *MockMenschServer) EXPECT() *_MockMenschServerRecorder

func (*MockMenschServer) Init 

func (_m *MockMenschServer) Init(_param0 context.Context, _param1 *InitRequest) (*InitResponse, error)

func (*MockMenschServer) Modify 

func (_m *MockMenschServer) Modify(_param0 context.Context, _param1 *ModifyRequest) (*ModifyResponse, error)

func (*MockMenschServer) Start 

func (_m *MockMenschServer) Start(_param0 context.Context, _param1 *StartRequest) (*StartResponse, error)

func (*MockMenschServer) Status 

func (_m *MockMenschServer) Status(_param0 context.Context, _param1 *StatusRequest) (*StatusResponse, error)

func (*MockMenschServer) Stop 

func (_m *MockMenschServer) Stop(_param0 context.Context, _param1 *StopRequest) (*StopResponse, error)

type ModifyRequest 

type ModifyRequest struct {
	Workload *Workload `protobuf:"bytes,1,opt,name=workload" json:"workload,omitempty"`
}

func (*ModifyRequest) Descriptor 

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

func (*ModifyRequest) GetWorkload 

func (m *ModifyRequest) GetWorkload() *Workload

func (*ModifyRequest) ProtoMessage 

func (*ModifyRequest) ProtoMessage()

func (*ModifyRequest) Reset 

func (m *ModifyRequest) Reset()

func (*ModifyRequest) String 

func (m *ModifyRequest) String() string

type ModifyResponse 

type ModifyResponse struct {
}

func (*ModifyResponse) Descriptor 

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

func (*ModifyResponse) ProtoMessage 

func (*ModifyResponse) ProtoMessage()

func (*ModifyResponse) Reset 

func (m *ModifyResponse) Reset()

func (*ModifyResponse) String 

func (m *ModifyResponse) String() string

type StartRequest 

type StartRequest struct {
}

func (*StartRequest) Descriptor 

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

func (*StartRequest) ProtoMessage 

func (*StartRequest) ProtoMessage()

func (*StartRequest) Reset 

func (m *StartRequest) Reset()

func (*StartRequest) String 

func (m *StartRequest) String() string

type StartResponse 

type StartResponse struct {
}

func (*StartResponse) Descriptor 

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

func (*StartResponse) ProtoMessage 

func (*StartResponse) ProtoMessage()

func (*StartResponse) Reset 

func (m *StartResponse) Reset()

func (*StartResponse) String 

func (m *StartResponse) String() string

type Status 

type Status int32
const (
	Status_UNKNOWN       Status = 0
	Status_UNINITIALIZED Status = 1
	Status_INITIALIZED   Status = 2
	Status_RUNNING       Status = 3
)

func (Status) EnumDescriptor 

func (Status) EnumDescriptor() ([]byte, []int)

func (Status) String 

func (x Status) String() string

type StatusRequest 

type StatusRequest struct {
}

func (*StatusRequest) Descriptor 

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

func (*StatusRequest) ProtoMessage 

func (*StatusRequest) ProtoMessage()

func (*StatusRequest) Reset 

func (m *StatusRequest) Reset()

func (*StatusRequest) String 

func (m *StatusRequest) String() string

type StatusResponse 

type StatusResponse struct {
	Status   Status    `protobuf:"varint,1,opt,name=status,enum=rpc.Status" json:"status,omitempty"`
	Token    string    `protobuf:"bytes,2,opt,name=token" json:"token,omitempty"`
	MaxQPS   int64     `protobuf:"varint,3,opt,name=maxQPS" json:"maxQPS,omitempty"`
	Workload *Workload `protobuf:"bytes,4,opt,name=workload" json:"workload,omitempty"`
}

func (*StatusResponse) Descriptor 

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

func (*StatusResponse) GetMaxQPS 

func (m *StatusResponse) GetMaxQPS() int64

func (*StatusResponse) GetStatus 

func (m *StatusResponse) GetStatus() Status

func (*StatusResponse) GetToken 

func (m *StatusResponse) GetToken() string

func (*StatusResponse) GetWorkload 

func (m *StatusResponse) GetWorkload() *Workload

func (*StatusResponse) ProtoMessage 

func (*StatusResponse) ProtoMessage()

func (*StatusResponse) Reset 

func (m *StatusResponse) Reset()

func (*StatusResponse) String 

func (m *StatusResponse) String() string

type StopRequest 

type StopRequest struct {
}

func (*StopRequest) Descriptor 

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

func (*StopRequest) ProtoMessage 

func (*StopRequest) ProtoMessage()

func (*StopRequest) Reset 

func (m *StopRequest) Reset()

func (*StopRequest) String 

func (m *StopRequest) String() string

type StopResponse 

type StopResponse struct {
}

func (*StopResponse) Descriptor 

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

func (*StopResponse) ProtoMessage 

func (*StopResponse) ProtoMessage()

func (*StopResponse) Reset 

func (m *StopResponse) Reset()

func (*StopResponse) String 

func (m *StopResponse) String() string

type Workload 

type Workload struct {
	BaseTime     *google_protobuf.Timestamp `protobuf:"bytes,1,opt,name=baseTime" json:"baseTime,omitempty"`
	MetricPrefix string                     `protobuf:"bytes,2,opt,name=metricPrefix" json:"metricPrefix,omitempty"`
	Namespace    string                     `protobuf:"bytes,3,opt,name=namespace" json:"namespace,omitempty"`
	Cardinality  int32                      `protobuf:"varint,4,opt,name=cardinality" json:"cardinality,omitempty"`
	IngressQPS   int32                      `protobuf:"varint,5,opt,name=ingressQPS" json:"ingressQPS,omitempty"`
}

func (*Workload) Descriptor 

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

func (*Workload) GetBaseTime 

func (m *Workload) GetBaseTime() *google_protobuf.Timestamp

func (*Workload) GetCardinality 

func (m *Workload) GetCardinality() int32

func (*Workload) GetIngressQPS 

func (m *Workload) GetIngressQPS() int32

func (*Workload) GetMetricPrefix 

func (m *Workload) GetMetricPrefix() string

func (*Workload) GetNamespace 

func (m *Workload) GetNamespace() string

func (*Workload) ProtoMessage 

func (*Workload) ProtoMessage()

func (*Workload) Reset 

func (m *Workload) Reset()

func (*Workload) String 

func (m *Workload) String() string

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.