Documentation
¶
Overview ¶
Package proto contains proto files and generated code.
Index ¶
- Variables
- func RegisterTrafficQuotaServer(s *grpc.Server, srv TrafficQuotaServer)
- type MockTrafficQuotaClient
- type MockTrafficQuotaClientMockRecorder
- type MockTrafficQuotaServer
- type MockTrafficQuotaServerMockRecorder
- type TakeRequest
- func (*TakeRequest) Descriptor() ([]byte, []int)
- func (m *TakeRequest) GetBucketKeys() []string
- func (m *TakeRequest) GetChunkKey() string
- func (m *TakeRequest) Marshal() (dAtA []byte, err error)
- func (m *TakeRequest) MarshalTo(dAtA []byte) (int, error)
- func (*TakeRequest) ProtoMessage()
- func (m *TakeRequest) Reset()
- func (m *TakeRequest) Size() (n int)
- func (m *TakeRequest) String() string
- func (m *TakeRequest) Unmarshal(dAtA []byte) error
- func (m *TakeRequest) XXX_DiscardUnknown()
- func (m *TakeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *TakeRequest) XXX_Merge(src proto.Message)
- func (m *TakeRequest) XXX_Size() int
- func (m *TakeRequest) XXX_Unmarshal(b []byte) error
- type TakeResponse
- func (*TakeResponse) Descriptor() ([]byte, []int)
- func (m *TakeResponse) GetAllowed() bool
- func (m *TakeResponse) Marshal() (dAtA []byte, err error)
- func (m *TakeResponse) MarshalTo(dAtA []byte) (int, error)
- func (*TakeResponse) ProtoMessage()
- func (m *TakeResponse) Reset()
- func (m *TakeResponse) Size() (n int)
- func (m *TakeResponse) String() string
- func (m *TakeResponse) Unmarshal(dAtA []byte) error
- func (m *TakeResponse) XXX_DiscardUnknown()
- func (m *TakeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *TakeResponse) XXX_Merge(src proto.Message)
- func (m *TakeResponse) XXX_Size() int
- func (m *TakeResponse) XXX_Unmarshal(b []byte) error
- type TrafficQuotaClient
- type TrafficQuotaServer
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthTrafficQuota = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowTrafficQuota = fmt.Errorf("proto: integer overflow") )
Functions ¶
func RegisterTrafficQuotaServer ¶
func RegisterTrafficQuotaServer(s *grpc.Server, srv TrafficQuotaServer)
Types ¶
type MockTrafficQuotaClient ¶
type MockTrafficQuotaClient struct {
// contains filtered or unexported fields
}
MockTrafficQuotaClient is a mock of TrafficQuotaClient interface
func NewMockTrafficQuotaClient ¶
func NewMockTrafficQuotaClient(ctrl *gomock.Controller) *MockTrafficQuotaClient
NewMockTrafficQuotaClient creates a new mock instance
func (*MockTrafficQuotaClient) EXPECT ¶
func (m *MockTrafficQuotaClient) EXPECT() *MockTrafficQuotaClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockTrafficQuotaClient) Take ¶
func (m *MockTrafficQuotaClient) Take(ctx context.Context, in *TakeRequest, opts ...grpc.CallOption) (*TakeResponse, error)
Take mocks base method
type MockTrafficQuotaClientMockRecorder ¶
type MockTrafficQuotaClientMockRecorder struct {
// contains filtered or unexported fields
}
MockTrafficQuotaClientMockRecorder is the mock recorder for MockTrafficQuotaClient
func (*MockTrafficQuotaClientMockRecorder) Take ¶
func (mr *MockTrafficQuotaClientMockRecorder) Take(ctx, in interface{}, opts ...interface{}) *gomock.Call
Take indicates an expected call of Take
type MockTrafficQuotaServer ¶
type MockTrafficQuotaServer struct {
// contains filtered or unexported fields
}
MockTrafficQuotaServer is a mock of TrafficQuotaServer interface
func NewMockTrafficQuotaServer ¶
func NewMockTrafficQuotaServer(ctrl *gomock.Controller) *MockTrafficQuotaServer
NewMockTrafficQuotaServer creates a new mock instance
func (*MockTrafficQuotaServer) EXPECT ¶
func (m *MockTrafficQuotaServer) EXPECT() *MockTrafficQuotaServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockTrafficQuotaServer) Take ¶
func (m *MockTrafficQuotaServer) Take(arg0 context.Context, arg1 *TakeRequest) (*TakeResponse, error)
Take mocks base method
type MockTrafficQuotaServerMockRecorder ¶
type MockTrafficQuotaServerMockRecorder struct {
// contains filtered or unexported fields
}
MockTrafficQuotaServerMockRecorder is the mock recorder for MockTrafficQuotaServer
func (*MockTrafficQuotaServerMockRecorder) Take ¶
func (mr *MockTrafficQuotaServerMockRecorder) Take(arg0, arg1 interface{}) *gomock.Call
Take indicates an expected call of Take
type TakeRequest ¶
type TakeRequest struct {
ChunkKey string `protobuf:"bytes,1,opt,name=chunk_key,json=chunkKey,proto3" json:"chunk_key,omitempty"`
BucketKeys []string `protobuf:"bytes,2,rep,name=bucket_keys,json=bucketKeys" json:"bucket_keys,omitempty"`
}
func (*TakeRequest) Descriptor ¶
func (*TakeRequest) Descriptor() ([]byte, []int)
func (*TakeRequest) GetBucketKeys ¶
func (m *TakeRequest) GetBucketKeys() []string
func (*TakeRequest) GetChunkKey ¶
func (m *TakeRequest) GetChunkKey() string
func (*TakeRequest) Marshal ¶
func (m *TakeRequest) Marshal() (dAtA []byte, err error)
func (*TakeRequest) ProtoMessage ¶
func (*TakeRequest) ProtoMessage()
func (*TakeRequest) Reset ¶
func (m *TakeRequest) Reset()
func (*TakeRequest) Size ¶
func (m *TakeRequest) Size() (n int)
func (*TakeRequest) String ¶
func (m *TakeRequest) String() string
func (*TakeRequest) Unmarshal ¶
func (m *TakeRequest) Unmarshal(dAtA []byte) error
func (*TakeRequest) XXX_DiscardUnknown ¶
func (m *TakeRequest) XXX_DiscardUnknown()
func (*TakeRequest) XXX_Marshal ¶
func (m *TakeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TakeRequest) XXX_Merge ¶
func (dst *TakeRequest) XXX_Merge(src proto.Message)
func (*TakeRequest) XXX_Size ¶
func (m *TakeRequest) XXX_Size() int
func (*TakeRequest) XXX_Unmarshal ¶
func (m *TakeRequest) XXX_Unmarshal(b []byte) error
type TakeResponse ¶
type TakeResponse struct {
Allowed bool `protobuf:"varint,1,opt,name=allowed,proto3" json:"allowed,omitempty"`
}
func (*TakeResponse) Descriptor ¶
func (*TakeResponse) Descriptor() ([]byte, []int)
func (*TakeResponse) GetAllowed ¶
func (m *TakeResponse) GetAllowed() bool
func (*TakeResponse) Marshal ¶
func (m *TakeResponse) Marshal() (dAtA []byte, err error)
func (*TakeResponse) ProtoMessage ¶
func (*TakeResponse) ProtoMessage()
func (*TakeResponse) Reset ¶
func (m *TakeResponse) Reset()
func (*TakeResponse) Size ¶
func (m *TakeResponse) Size() (n int)
func (*TakeResponse) String ¶
func (m *TakeResponse) String() string
func (*TakeResponse) Unmarshal ¶
func (m *TakeResponse) Unmarshal(dAtA []byte) error
func (*TakeResponse) XXX_DiscardUnknown ¶
func (m *TakeResponse) XXX_DiscardUnknown()
func (*TakeResponse) XXX_Marshal ¶
func (m *TakeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TakeResponse) XXX_Merge ¶
func (dst *TakeResponse) XXX_Merge(src proto.Message)
func (*TakeResponse) XXX_Size ¶
func (m *TakeResponse) XXX_Size() int
func (*TakeResponse) XXX_Unmarshal ¶
func (m *TakeResponse) XXX_Unmarshal(b []byte) error
type TrafficQuotaClient ¶
type TrafficQuotaClient interface {
Take(ctx context.Context, in *TakeRequest, opts ...grpc.CallOption) (*TakeResponse, error)
}
TrafficQuotaClient is the client API for TrafficQuota service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewTrafficQuotaClient ¶
func NewTrafficQuotaClient(cc *grpc.ClientConn) TrafficQuotaClient
type TrafficQuotaServer ¶
type TrafficQuotaServer interface {
Take(context.Context, *TakeRequest) (*TakeResponse, error)
}
TrafficQuotaServer is the server API for TrafficQuota service.
Source Files
Click to show internal directories.
Click to hide internal directories.