m3nsch

package
v0.15.7 Latest Latest
Warning

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

Go to latest
Published: Aug 1, 2020 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Overview

Package m3nsch is a generated protocol buffer package.

It is generated from these files:
	github.com/m3db/m3/src/m3nsch/generated/proto/m3nsch/m3nsch.proto

It has these top-level messages:
	StatusRequest
	StatusResponse
	InitRequest
	InitResponse
	ModifyRequest
	ModifyResponse
	StartRequest
	StartResponse
	StopRequest
	StopResponse
	Workload

Package m3nsch is a generated GoMock package.

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthM3Nsch = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowM3Nsch   = fmt.Errorf("proto: integer overflow")
)
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,proto3" json:"token,omitempty"`
	Workload   *Workload `protobuf:"bytes,2,opt,name=workload" json:"workload,omitempty"`
	Force      bool      `protobuf:"varint,3,opt,name=force,proto3" json:"force,omitempty"`
	TargetZone string    `protobuf:"bytes,4,opt,name=targetZone,proto3" json:"targetZone,omitempty"`
	TargetEnv  string    `protobuf:"bytes,5,opt,name=targetEnv,proto3" 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) Marshal

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

func (*InitRequest) MarshalTo

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

func (*InitRequest) ProtoMessage

func (*InitRequest) ProtoMessage()

func (*InitRequest) Reset

func (m *InitRequest) Reset()

func (*InitRequest) Size

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

func (*InitRequest) String

func (m *InitRequest) String() string

func (*InitRequest) Unmarshal

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

type InitResponse

type InitResponse struct {
}

func (*InitResponse) Descriptor

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

func (*InitResponse) Marshal

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

func (*InitResponse) MarshalTo

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

func (*InitResponse) ProtoMessage

func (*InitResponse) ProtoMessage()

func (*InitResponse) Reset

func (m *InitResponse) Reset()

func (*InitResponse) Size

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

func (*InitResponse) String

func (m *InitResponse) String() string

func (*InitResponse) Unmarshal

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

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 MockMenschClient

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

MockMenschClient is a mock of MenschClient interface

func NewMockMenschClient

func NewMockMenschClient(ctrl *gomock.Controller) *MockMenschClient

NewMockMenschClient creates a new mock instance

func (*MockMenschClient) EXPECT

EXPECT returns an object that allows the caller to indicate expected use

func (*MockMenschClient) Init

Init mocks base method

func (*MockMenschClient) Modify

Modify mocks base method

func (*MockMenschClient) Start

Start mocks base method

func (*MockMenschClient) Status

Status mocks base method

func (*MockMenschClient) Stop

Stop mocks base method

type MockMenschClientMockRecorder

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

MockMenschClientMockRecorder is the mock recorder for MockMenschClient

func (*MockMenschClientMockRecorder) Init

func (mr *MockMenschClientMockRecorder) Init(ctx, in interface{}, opts ...interface{}) *gomock.Call

Init indicates an expected call of Init

func (*MockMenschClientMockRecorder) Modify

func (mr *MockMenschClientMockRecorder) Modify(ctx, in interface{}, opts ...interface{}) *gomock.Call

Modify indicates an expected call of Modify

func (*MockMenschClientMockRecorder) Start

func (mr *MockMenschClientMockRecorder) Start(ctx, in interface{}, opts ...interface{}) *gomock.Call

Start indicates an expected call of Start

func (*MockMenschClientMockRecorder) Status

func (mr *MockMenschClientMockRecorder) Status(ctx, in interface{}, opts ...interface{}) *gomock.Call

Status indicates an expected call of Status

func (*MockMenschClientMockRecorder) Stop

func (mr *MockMenschClientMockRecorder) Stop(ctx, in interface{}, opts ...interface{}) *gomock.Call

Stop indicates an expected call of Stop

type MockMenschServer

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

MockMenschServer is a mock of MenschServer interface

func NewMockMenschServer

func NewMockMenschServer(ctrl *gomock.Controller) *MockMenschServer

NewMockMenschServer creates a new mock instance

func (*MockMenschServer) EXPECT

EXPECT returns an object that allows the caller to indicate expected use

func (*MockMenschServer) Init

func (m *MockMenschServer) Init(arg0 context.Context, arg1 *InitRequest) (*InitResponse, error)

Init mocks base method

func (*MockMenschServer) Modify

Modify mocks base method

func (*MockMenschServer) Start

func (m *MockMenschServer) Start(arg0 context.Context, arg1 *StartRequest) (*StartResponse, error)

Start mocks base method

func (*MockMenschServer) Status

Status mocks base method

func (*MockMenschServer) Stop

func (m *MockMenschServer) Stop(arg0 context.Context, arg1 *StopRequest) (*StopResponse, error)

Stop mocks base method

type MockMenschServerMockRecorder

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

MockMenschServerMockRecorder is the mock recorder for MockMenschServer

func (*MockMenschServerMockRecorder) Init

func (mr *MockMenschServerMockRecorder) Init(arg0, arg1 interface{}) *gomock.Call

Init indicates an expected call of Init

func (*MockMenschServerMockRecorder) Modify

func (mr *MockMenschServerMockRecorder) Modify(arg0, arg1 interface{}) *gomock.Call

Modify indicates an expected call of Modify

func (*MockMenschServerMockRecorder) Start

func (mr *MockMenschServerMockRecorder) Start(arg0, arg1 interface{}) *gomock.Call

Start indicates an expected call of Start

func (*MockMenschServerMockRecorder) Status

func (mr *MockMenschServerMockRecorder) Status(arg0, arg1 interface{}) *gomock.Call

Status indicates an expected call of Status

func (*MockMenschServerMockRecorder) Stop

func (mr *MockMenschServerMockRecorder) Stop(arg0, arg1 interface{}) *gomock.Call

Stop indicates an expected call of Stop

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) Marshal

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

func (*ModifyRequest) MarshalTo

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

func (*ModifyRequest) ProtoMessage

func (*ModifyRequest) ProtoMessage()

func (*ModifyRequest) Reset

func (m *ModifyRequest) Reset()

func (*ModifyRequest) Size

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

func (*ModifyRequest) String

func (m *ModifyRequest) String() string

func (*ModifyRequest) Unmarshal

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

type ModifyResponse

type ModifyResponse struct {
}

func (*ModifyResponse) Descriptor

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

func (*ModifyResponse) Marshal

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

func (*ModifyResponse) MarshalTo

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

func (*ModifyResponse) ProtoMessage

func (*ModifyResponse) ProtoMessage()

func (*ModifyResponse) Reset

func (m *ModifyResponse) Reset()

func (*ModifyResponse) Size

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

func (*ModifyResponse) String

func (m *ModifyResponse) String() string

func (*ModifyResponse) Unmarshal

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

type StartRequest

type StartRequest struct {
}

func (*StartRequest) Descriptor

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

func (*StartRequest) Marshal

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

func (*StartRequest) MarshalTo

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

func (*StartRequest) ProtoMessage

func (*StartRequest) ProtoMessage()

func (*StartRequest) Reset

func (m *StartRequest) Reset()

func (*StartRequest) Size

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

func (*StartRequest) String

func (m *StartRequest) String() string

func (*StartRequest) Unmarshal

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

type StartResponse

type StartResponse struct {
}

func (*StartResponse) Descriptor

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

func (*StartResponse) Marshal

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

func (*StartResponse) MarshalTo

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

func (*StartResponse) ProtoMessage

func (*StartResponse) ProtoMessage()

func (*StartResponse) Reset

func (m *StartResponse) Reset()

func (*StartResponse) Size

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

func (*StartResponse) String

func (m *StartResponse) String() string

func (*StartResponse) Unmarshal

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

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) Marshal

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

func (*StatusRequest) MarshalTo

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

func (*StatusRequest) ProtoMessage

func (*StatusRequest) ProtoMessage()

func (*StatusRequest) Reset

func (m *StatusRequest) Reset()

func (*StatusRequest) Size

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

func (*StatusRequest) String

func (m *StatusRequest) String() string

func (*StatusRequest) Unmarshal

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

type StatusResponse

type StatusResponse struct {
	Status   Status    `protobuf:"varint,1,opt,name=status,proto3,enum=m3nsch.Status" json:"status,omitempty"`
	Token    string    `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	MaxQPS   int64     `protobuf:"varint,3,opt,name=maxQPS,proto3" 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) Marshal

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

func (*StatusResponse) MarshalTo

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

func (*StatusResponse) ProtoMessage

func (*StatusResponse) ProtoMessage()

func (*StatusResponse) Reset

func (m *StatusResponse) Reset()

func (*StatusResponse) Size

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

func (*StatusResponse) String

func (m *StatusResponse) String() string

func (*StatusResponse) Unmarshal

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

type StopRequest

type StopRequest struct {
}

func (*StopRequest) Descriptor

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

func (*StopRequest) Marshal

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

func (*StopRequest) MarshalTo

func (m *StopRequest) MarshalTo(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

type StopResponse

type StopResponse struct {
}

func (*StopResponse) Descriptor

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

func (*StopResponse) Marshal

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

func (*StopResponse) MarshalTo

func (m *StopResponse) MarshalTo(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

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,proto3" json:"metricPrefix,omitempty"`
	Namespace       string                     `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Cardinality     int32                      `protobuf:"varint,4,opt,name=cardinality,proto3" json:"cardinality,omitempty"`
	IngressQPS      int32                      `protobuf:"varint,5,opt,name=ingressQPS,proto3" json:"ingressQPS,omitempty"`
	UniqueAmplifier float64                    `protobuf:"fixed64,6,opt,name=uniqueAmplifier,proto3" json:"uniqueAmplifier,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) GetUniqueAmplifier added in v0.7.0

func (m *Workload) GetUniqueAmplifier() float64

func (*Workload) Marshal

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

func (*Workload) MarshalTo

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

func (*Workload) ProtoMessage

func (*Workload) ProtoMessage()

func (*Workload) Reset

func (m *Workload) Reset()

func (*Workload) Size

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

func (*Workload) String

func (m *Workload) String() string

func (*Workload) Unmarshal

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

Jump to

Keyboard shortcuts

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