m3nsch

package
v0.14.3 Latest Latest
Warning

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

 Go to latest Published: Apr 22, 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 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
}

MockMenschClient is a mock of MenschClient interface

func NewMockMenschClient 

func NewMockMenschClient(ctrl *gomock.Controller) *MockMenschClient

NewMockMenschClient creates a new mock instance

func (*MockMenschClient) EXPECT 

func (m *MockMenschClient) EXPECT() *MockMenschClientMockRecorder

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

func (*MockMenschClient) Init 

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

Init mocks base method

func (*MockMenschClient) Modify 

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

Modify mocks base method

func (*MockMenschClient) Start 

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

Start mocks base method

func (*MockMenschClient) Status 

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

Status mocks base method

func (*MockMenschClient) Stop 

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

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 

func (m *MockMenschServer) EXPECT() *MockMenschServerMockRecorder

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 

func (m *MockMenschServer) Modify(arg0 context.Context, arg1 *ModifyRequest) (*ModifyResponse, error)

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 

func (m *MockMenschServer) Status(arg0 context.Context, arg1 *StatusRequest) (*StatusResponse, error)

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

Source Files

View all Source files

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.