proto

package
v3.6.13 Latest Latest
Warning

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

 Go to latest Published: Jul 23, 2026 License: AGPL-3.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthLimits = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowLimits   = fmt.Errorf("proto: integer overflow")
)

Functions

func RegisterIngestLimitsFrontendServer 

func RegisterIngestLimitsFrontendServer(s *grpc.Server, srv IngestLimitsFrontendServer)

func RegisterIngestLimitsServer 

func RegisterIngestLimitsServer(s *grpc.Server, srv IngestLimitsServer)

Types

type ExceedsLimitsRequest 

type ExceedsLimitsRequest struct {
	Tenant  string            `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	Streams []*StreamMetadata `protobuf:"bytes,2,rep,name=streams,proto3" json:"streams,omitempty"`
}

func (*ExceedsLimitsRequest) Descriptor 

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

func (*ExceedsLimitsRequest) Equal 

func (this *ExceedsLimitsRequest) Equal(that interface{}) bool

func (*ExceedsLimitsRequest) GetStreams 

func (m *ExceedsLimitsRequest) GetStreams() []*StreamMetadata

func (*ExceedsLimitsRequest) GetTenant 

func (m *ExceedsLimitsRequest) GetTenant() string

func (*ExceedsLimitsRequest) GoString 

func (this *ExceedsLimitsRequest) GoString() string

func (*ExceedsLimitsRequest) Marshal 

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

func (*ExceedsLimitsRequest) MarshalTo 

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

func (*ExceedsLimitsRequest) MarshalToSizedBuffer 

func (m *ExceedsLimitsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ExceedsLimitsRequest) ProtoMessage 

func (*ExceedsLimitsRequest) ProtoMessage()

func (*ExceedsLimitsRequest) Reset 

func (m *ExceedsLimitsRequest) Reset()

func (*ExceedsLimitsRequest) Size 

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

func (*ExceedsLimitsRequest) String 

func (this *ExceedsLimitsRequest) String() string

func (*ExceedsLimitsRequest) Unmarshal 

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

func (*ExceedsLimitsRequest) XXX_DiscardUnknown 

func (m *ExceedsLimitsRequest) XXX_DiscardUnknown()

func (*ExceedsLimitsRequest) XXX_Marshal 

func (m *ExceedsLimitsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExceedsLimitsRequest) XXX_Merge 

func (m *ExceedsLimitsRequest) XXX_Merge(src proto.Message)

func (*ExceedsLimitsRequest) XXX_Size 

func (m *ExceedsLimitsRequest) XXX_Size() int

func (*ExceedsLimitsRequest) XXX_Unmarshal 

func (m *ExceedsLimitsRequest) XXX_Unmarshal(b []byte) error

type ExceedsLimitsResponse 

type ExceedsLimitsResponse struct {
	Results []*ExceedsLimitsResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
}

func (*ExceedsLimitsResponse) Descriptor 

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

func (*ExceedsLimitsResponse) Equal 

func (this *ExceedsLimitsResponse) Equal(that interface{}) bool

func (*ExceedsLimitsResponse) GetResults 

func (m *ExceedsLimitsResponse) GetResults() []*ExceedsLimitsResult

func (*ExceedsLimitsResponse) GoString 

func (this *ExceedsLimitsResponse) GoString() string

func (*ExceedsLimitsResponse) Marshal 

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

func (*ExceedsLimitsResponse) MarshalTo 

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

func (*ExceedsLimitsResponse) MarshalToSizedBuffer 

func (m *ExceedsLimitsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ExceedsLimitsResponse) ProtoMessage 

func (*ExceedsLimitsResponse) ProtoMessage()

func (*ExceedsLimitsResponse) Reset 

func (m *ExceedsLimitsResponse) Reset()

func (*ExceedsLimitsResponse) Size 

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

func (*ExceedsLimitsResponse) String 

func (this *ExceedsLimitsResponse) String() string

func (*ExceedsLimitsResponse) Unmarshal 

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

func (*ExceedsLimitsResponse) XXX_DiscardUnknown 

func (m *ExceedsLimitsResponse) XXX_DiscardUnknown()

func (*ExceedsLimitsResponse) XXX_Marshal 

func (m *ExceedsLimitsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExceedsLimitsResponse) XXX_Merge 

func (m *ExceedsLimitsResponse) XXX_Merge(src proto.Message)

func (*ExceedsLimitsResponse) XXX_Size 

func (m *ExceedsLimitsResponse) XXX_Size() int

func (*ExceedsLimitsResponse) XXX_Unmarshal 

func (m *ExceedsLimitsResponse) XXX_Unmarshal(b []byte) error

type ExceedsLimitsResult 

type ExceedsLimitsResult struct {
	StreamHash uint64 `protobuf:"varint,1,opt,name=streamHash,proto3" json:"streamHash,omitempty"`
	Reason     uint32 `protobuf:"varint,2,opt,name=reason,proto3" json:"reason,omitempty"`
}

func (*ExceedsLimitsResult) Descriptor 

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

func (*ExceedsLimitsResult) Equal 

func (this *ExceedsLimitsResult) Equal(that interface{}) bool

func (*ExceedsLimitsResult) GetReason 

func (m *ExceedsLimitsResult) GetReason() uint32

func (*ExceedsLimitsResult) GetStreamHash 

func (m *ExceedsLimitsResult) GetStreamHash() uint64

func (*ExceedsLimitsResult) GoString 

func (this *ExceedsLimitsResult) GoString() string

func (*ExceedsLimitsResult) Marshal 

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

func (*ExceedsLimitsResult) MarshalTo 

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

func (*ExceedsLimitsResult) MarshalToSizedBuffer 

func (m *ExceedsLimitsResult) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ExceedsLimitsResult) ProtoMessage 

func (*ExceedsLimitsResult) ProtoMessage()

func (*ExceedsLimitsResult) Reset 

func (m *ExceedsLimitsResult) Reset()

func (*ExceedsLimitsResult) Size 

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

func (*ExceedsLimitsResult) String 

func (this *ExceedsLimitsResult) String() string

func (*ExceedsLimitsResult) Unmarshal 

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

func (*ExceedsLimitsResult) XXX_DiscardUnknown 

func (m *ExceedsLimitsResult) XXX_DiscardUnknown()

func (*ExceedsLimitsResult) XXX_Marshal 

func (m *ExceedsLimitsResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExceedsLimitsResult) XXX_Merge 

func (m *ExceedsLimitsResult) XXX_Merge(src proto.Message)

func (*ExceedsLimitsResult) XXX_Size 

func (m *ExceedsLimitsResult) XXX_Size() int

func (*ExceedsLimitsResult) XXX_Unmarshal 

func (m *ExceedsLimitsResult) XXX_Unmarshal(b []byte) error

type GetAssignedPartitionsRequest 

type GetAssignedPartitionsRequest struct {
}

func (*GetAssignedPartitionsRequest) Descriptor 

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

func (*GetAssignedPartitionsRequest) Equal 

func (this *GetAssignedPartitionsRequest) Equal(that interface{}) bool

func (*GetAssignedPartitionsRequest) GoString 

func (this *GetAssignedPartitionsRequest) GoString() string

func (*GetAssignedPartitionsRequest) Marshal 

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

func (*GetAssignedPartitionsRequest) MarshalTo 

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

func (*GetAssignedPartitionsRequest) MarshalToSizedBuffer 

func (m *GetAssignedPartitionsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetAssignedPartitionsRequest) ProtoMessage 

func (*GetAssignedPartitionsRequest) ProtoMessage()

func (*GetAssignedPartitionsRequest) Reset 

func (m *GetAssignedPartitionsRequest) Reset()

func (*GetAssignedPartitionsRequest) Size 

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

func (*GetAssignedPartitionsRequest) String 

func (this *GetAssignedPartitionsRequest) String() string

func (*GetAssignedPartitionsRequest) Unmarshal 

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

func (*GetAssignedPartitionsRequest) XXX_DiscardUnknown 

func (m *GetAssignedPartitionsRequest) XXX_DiscardUnknown()

func (*GetAssignedPartitionsRequest) XXX_Marshal 

func (m *GetAssignedPartitionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetAssignedPartitionsRequest) XXX_Merge 

func (m *GetAssignedPartitionsRequest) XXX_Merge(src proto.Message)

func (*GetAssignedPartitionsRequest) XXX_Size 

func (m *GetAssignedPartitionsRequest) XXX_Size() int

func (*GetAssignedPartitionsRequest) XXX_Unmarshal 

func (m *GetAssignedPartitionsRequest) XXX_Unmarshal(b []byte) error

type GetAssignedPartitionsResponse 

type GetAssignedPartitionsResponse struct {
	AssignedPartitions map[int32]int64 `` /* 179-byte string literal not displayed */
}

func (*GetAssignedPartitionsResponse) Descriptor 

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

func (*GetAssignedPartitionsResponse) Equal 

func (this *GetAssignedPartitionsResponse) Equal(that interface{}) bool

func (*GetAssignedPartitionsResponse) GetAssignedPartitions 

func (m *GetAssignedPartitionsResponse) GetAssignedPartitions() map[int32]int64

func (*GetAssignedPartitionsResponse) GoString 

func (this *GetAssignedPartitionsResponse) GoString() string

func (*GetAssignedPartitionsResponse) Marshal 

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

func (*GetAssignedPartitionsResponse) MarshalTo 

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

func (*GetAssignedPartitionsResponse) MarshalToSizedBuffer 

func (m *GetAssignedPartitionsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetAssignedPartitionsResponse) ProtoMessage 

func (*GetAssignedPartitionsResponse) ProtoMessage()

func (*GetAssignedPartitionsResponse) Reset 

func (m *GetAssignedPartitionsResponse) Reset()

func (*GetAssignedPartitionsResponse) Size 

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

func (*GetAssignedPartitionsResponse) String 

func (this *GetAssignedPartitionsResponse) String() string

func (*GetAssignedPartitionsResponse) Unmarshal 

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

func (*GetAssignedPartitionsResponse) XXX_DiscardUnknown 

func (m *GetAssignedPartitionsResponse) XXX_DiscardUnknown()

func (*GetAssignedPartitionsResponse) XXX_Marshal 

func (m *GetAssignedPartitionsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetAssignedPartitionsResponse) XXX_Merge 

func (m *GetAssignedPartitionsResponse) XXX_Merge(src proto.Message)

func (*GetAssignedPartitionsResponse) XXX_Size 

func (m *GetAssignedPartitionsResponse) XXX_Size() int

func (*GetAssignedPartitionsResponse) XXX_Unmarshal 

func (m *GetAssignedPartitionsResponse) XXX_Unmarshal(b []byte) error

type IngestLimitsClient 

type IngestLimitsClient interface {
	ExceedsLimits(ctx context.Context, in *ExceedsLimitsRequest, opts ...grpc.CallOption) (*ExceedsLimitsResponse, error)
	GetAssignedPartitions(ctx context.Context, in *GetAssignedPartitionsRequest, opts ...grpc.CallOption) (*GetAssignedPartitionsResponse, error)
}

IngestLimitsClient is the client API for IngestLimits service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewIngestLimitsClient 

func NewIngestLimitsClient(cc *grpc.ClientConn) IngestLimitsClient

type IngestLimitsFrontendClient 

type IngestLimitsFrontendClient interface {
	ExceedsLimits(ctx context.Context, in *ExceedsLimitsRequest, opts ...grpc.CallOption) (*ExceedsLimitsResponse, error)
}

IngestLimitsFrontendClient is the client API for IngestLimitsFrontend service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewIngestLimitsFrontendClient 

func NewIngestLimitsFrontendClient(cc *grpc.ClientConn) IngestLimitsFrontendClient

type IngestLimitsFrontendServer 

type IngestLimitsFrontendServer interface {
	ExceedsLimits(context.Context, *ExceedsLimitsRequest) (*ExceedsLimitsResponse, error)
}

IngestLimitsFrontendServer is the server API for IngestLimitsFrontend service.

type IngestLimitsServer 

type IngestLimitsServer interface {
	ExceedsLimits(context.Context, *ExceedsLimitsRequest) (*ExceedsLimitsResponse, error)
	GetAssignedPartitions(context.Context, *GetAssignedPartitionsRequest) (*GetAssignedPartitionsResponse, error)
}

IngestLimitsServer is the server API for IngestLimits service.

type StreamMetadata 

type StreamMetadata struct {
	StreamHash uint64 `protobuf:"varint,1,opt,name=streamHash,proto3" json:"streamHash,omitempty"`
	TotalSize  uint64 `protobuf:"varint,2,opt,name=totalSize,proto3" json:"totalSize,omitempty"`
}

func (*StreamMetadata) Descriptor 

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

func (*StreamMetadata) Equal 

func (this *StreamMetadata) Equal(that interface{}) bool

func (*StreamMetadata) GetStreamHash 

func (m *StreamMetadata) GetStreamHash() uint64

func (*StreamMetadata) GetTotalSize 

func (m *StreamMetadata) GetTotalSize() uint64

func (*StreamMetadata) GoString 

func (this *StreamMetadata) GoString() string

func (*StreamMetadata) Marshal 

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

func (*StreamMetadata) MarshalTo 

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

func (*StreamMetadata) MarshalToSizedBuffer 

func (m *StreamMetadata) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StreamMetadata) ProtoMessage 

func (*StreamMetadata) ProtoMessage()

func (*StreamMetadata) Reset 

func (m *StreamMetadata) Reset()

func (*StreamMetadata) Size 

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

func (*StreamMetadata) String 

func (this *StreamMetadata) String() string

func (*StreamMetadata) Unmarshal 

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

func (*StreamMetadata) XXX_DiscardUnknown 

func (m *StreamMetadata) XXX_DiscardUnknown()

func (*StreamMetadata) XXX_Marshal 

func (m *StreamMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamMetadata) XXX_Merge 

func (m *StreamMetadata) XXX_Merge(src proto.Message)

func (*StreamMetadata) XXX_Size 

func (m *StreamMetadata) XXX_Size() int

func (*StreamMetadata) XXX_Unmarshal 

func (m *StreamMetadata) XXX_Unmarshal(b []byte) error

type StreamMetadataRecord 

type StreamMetadataRecord struct {
	Zone     string          `protobuf:"bytes,1,opt,name=zone,proto3" json:"zone,omitempty"`
	Tenant   string          `protobuf:"bytes,2,opt,name=tenant,proto3" json:"tenant,omitempty"`
	Metadata *StreamMetadata `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
}

func (*StreamMetadataRecord) Descriptor 

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

func (*StreamMetadataRecord) Equal 

func (this *StreamMetadataRecord) Equal(that interface{}) bool

func (*StreamMetadataRecord) GetMetadata 

func (m *StreamMetadataRecord) GetMetadata() *StreamMetadata

func (*StreamMetadataRecord) GetTenant 

func (m *StreamMetadataRecord) GetTenant() string

func (*StreamMetadataRecord) GetZone 

func (m *StreamMetadataRecord) GetZone() string

func (*StreamMetadataRecord) GoString 

func (this *StreamMetadataRecord) GoString() string

func (*StreamMetadataRecord) Marshal 

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

func (*StreamMetadataRecord) MarshalTo 

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

func (*StreamMetadataRecord) MarshalToSizedBuffer 

func (m *StreamMetadataRecord) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StreamMetadataRecord) ProtoMessage 

func (*StreamMetadataRecord) ProtoMessage()

func (*StreamMetadataRecord) Reset 

func (m *StreamMetadataRecord) Reset()

func (*StreamMetadataRecord) Size 

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

func (*StreamMetadataRecord) String 

func (this *StreamMetadataRecord) String() string

func (*StreamMetadataRecord) Unmarshal 

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

func (*StreamMetadataRecord) XXX_DiscardUnknown 

func (m *StreamMetadataRecord) XXX_DiscardUnknown()

func (*StreamMetadataRecord) XXX_Marshal 

func (m *StreamMetadataRecord) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamMetadataRecord) XXX_Merge 

func (m *StreamMetadataRecord) XXX_Merge(src proto.Message)

func (*StreamMetadataRecord) XXX_Size 

func (m *StreamMetadataRecord) XXX_Size() int

func (*StreamMetadataRecord) XXX_Unmarshal 

func (m *StreamMetadataRecord) XXX_Unmarshal(b []byte) error

type UnimplementedIngestLimitsFrontendServer 

type UnimplementedIngestLimitsFrontendServer struct {
}

UnimplementedIngestLimitsFrontendServer can be embedded to have forward compatible implementations.

func (*UnimplementedIngestLimitsFrontendServer) ExceedsLimits 

func (*UnimplementedIngestLimitsFrontendServer) ExceedsLimits(ctx context.Context, req *ExceedsLimitsRequest) (*ExceedsLimitsResponse, error)

type UnimplementedIngestLimitsServer 

type UnimplementedIngestLimitsServer struct {
}

UnimplementedIngestLimitsServer can be embedded to have forward compatible implementations.

func (*UnimplementedIngestLimitsServer) ExceedsLimits 

func (*UnimplementedIngestLimitsServer) ExceedsLimits(ctx context.Context, req *ExceedsLimitsRequest) (*ExceedsLimitsResponse, error)

func (*UnimplementedIngestLimitsServer) GetAssignedPartitions 

func (*UnimplementedIngestLimitsServer) GetAssignedPartitions(ctx context.Context, req *GetAssignedPartitionsRequest) (*GetAssignedPartitionsResponse, 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.