grpc

Dec 18, 2022 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Oct 4, 2022 GO-2022-1175 +1 more

  GO-2022-1175: Exposure of local files in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Jul 15, 2022 GO-2022-1175 +1 more

  GO-2022-1175: Exposure of local files in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Jul 6, 2022 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Jun 23, 2022 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Mar 17, 2022 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Mar 8, 2022 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Nov 25, 2021 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Nov 4, 2021 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Oct 4, 2021 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Aug 3, 2021 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Jul 21, 2021 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Jun 29, 2021 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

May 14, 2021 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Apr 29, 2021 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Apr 19, 2021 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Mar 25, 2021 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Mar 15, 2021 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Mar 8, 2021 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Apr 19, 2021 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Feb 23, 2021 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Feb 19, 2021 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Feb 14, 2021 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Jan 21, 2021 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Dec 29, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Dec 19, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Dec 9, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Nov 9, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Oct 29, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Nov 3, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Oct 29, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Oct 2, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Sep 22, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Sep 16, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Aug 21, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Aug 17, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Aug 10, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Aug 5, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Jul 1, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Changes in this version

+ var ErrIntOverflowGrpc = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthGrpc = fmt.Errorf("proto: negative length found during unmarshaling")

+ func RegisterGrpcStoreServer(s *grpc.Server, srv GrpcStoreServer)

+ type Chunk struct

+ Encoded []byte

+ Key string

+ TableName string

+ func (*Chunk) Descriptor() ([]byte, []int)

+ func (*Chunk) ProtoMessage()

+ func (m *Chunk) GetEncoded() []byte

+ func (m *Chunk) GetKey() string

+ func (m *Chunk) GetTableName() string

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

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

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

+ func (m *Chunk) Reset()

+ func (m *Chunk) Size() (n int)

+ func (m *Chunk) Unmarshal(dAtA []byte) error

+ func (m *Chunk) XXX_DiscardUnknown()

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

+ func (m *Chunk) XXX_Merge(src proto.Message)

+ func (m *Chunk) XXX_Size() int

+ func (m *Chunk) XXX_Unmarshal(b []byte) error

+ func (this *Chunk) Equal(that interface{}) bool

+ func (this *Chunk) GoString() string

+ func (this *Chunk) String() string

+ type ChunkID struct

+ ChunkID string

+ func (*ChunkID) Descriptor() ([]byte, []int)

+ func (*ChunkID) ProtoMessage()

+ func (m *ChunkID) GetChunkID() string

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

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

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

+ func (m *ChunkID) Reset()

+ func (m *ChunkID) Size() (n int)

+ func (m *ChunkID) Unmarshal(dAtA []byte) error

+ func (m *ChunkID) XXX_DiscardUnknown()

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

+ func (m *ChunkID) XXX_Merge(src proto.Message)

+ func (m *ChunkID) XXX_Size() int

+ func (m *ChunkID) XXX_Unmarshal(b []byte) error

+ func (this *ChunkID) Equal(that interface{}) bool

+ func (this *ChunkID) GoString() string

+ func (this *ChunkID) String() string

+ type Config struct

+ Address string

+ func (cfg *Config) RegisterFlags(f *flag.FlagSet)

+ type CreateTableRequest struct

+ Desc *TableDesc

+ func (*CreateTableRequest) Descriptor() ([]byte, []int)

+ func (*CreateTableRequest) ProtoMessage()

+ func (m *CreateTableRequest) GetDesc() *TableDesc

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

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

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

+ func (m *CreateTableRequest) Reset()

+ func (m *CreateTableRequest) Size() (n int)

+ func (m *CreateTableRequest) Unmarshal(dAtA []byte) error

+ func (m *CreateTableRequest) XXX_DiscardUnknown()

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

+ func (m *CreateTableRequest) XXX_Merge(src proto.Message)

+ func (m *CreateTableRequest) XXX_Size() int

+ func (m *CreateTableRequest) XXX_Unmarshal(b []byte) error

+ func (this *CreateTableRequest) Equal(that interface{}) bool

+ func (this *CreateTableRequest) GoString() string

+ func (this *CreateTableRequest) String() string

+ type DeleteIndexRequest struct

+ Deletes []*IndexEntry

+ func (*DeleteIndexRequest) Descriptor() ([]byte, []int)

+ func (*DeleteIndexRequest) ProtoMessage()

+ func (m *DeleteIndexRequest) GetDeletes() []*IndexEntry

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

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

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

+ func (m *DeleteIndexRequest) Reset()

+ func (m *DeleteIndexRequest) Size() (n int)

+ func (m *DeleteIndexRequest) Unmarshal(dAtA []byte) error

+ func (m *DeleteIndexRequest) XXX_DiscardUnknown()

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

+ func (m *DeleteIndexRequest) XXX_Merge(src proto.Message)

+ func (m *DeleteIndexRequest) XXX_Size() int

+ func (m *DeleteIndexRequest) XXX_Unmarshal(b []byte) error

+ func (this *DeleteIndexRequest) Equal(that interface{}) bool

+ func (this *DeleteIndexRequest) GoString() string

+ func (this *DeleteIndexRequest) String() string

+ type DeleteTableRequest struct

+ TableName string

+ func (*DeleteTableRequest) Descriptor() ([]byte, []int)

+ func (*DeleteTableRequest) ProtoMessage()

+ func (m *DeleteTableRequest) GetTableName() string

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

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

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

+ func (m *DeleteTableRequest) Reset()

+ func (m *DeleteTableRequest) Size() (n int)

+ func (m *DeleteTableRequest) Unmarshal(dAtA []byte) error

+ func (m *DeleteTableRequest) XXX_DiscardUnknown()

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

+ func (m *DeleteTableRequest) XXX_Merge(src proto.Message)

+ func (m *DeleteTableRequest) XXX_Size() int

+ func (m *DeleteTableRequest) XXX_Unmarshal(b []byte) error

+ func (this *DeleteTableRequest) Equal(that interface{}) bool

+ func (this *DeleteTableRequest) GoString() string

+ func (this *DeleteTableRequest) String() string

+ type DescribeTableRequest struct

+ TableName string

+ func (*DescribeTableRequest) Descriptor() ([]byte, []int)

+ func (*DescribeTableRequest) ProtoMessage()

+ func (m *DescribeTableRequest) GetTableName() string

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

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

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

+ func (m *DescribeTableRequest) Reset()

+ func (m *DescribeTableRequest) Size() (n int)

+ func (m *DescribeTableRequest) Unmarshal(dAtA []byte) error

+ func (m *DescribeTableRequest) XXX_DiscardUnknown()

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

+ func (m *DescribeTableRequest) XXX_Merge(src proto.Message)

+ func (m *DescribeTableRequest) XXX_Size() int

+ func (m *DescribeTableRequest) XXX_Unmarshal(b []byte) error

+ func (this *DescribeTableRequest) Equal(that interface{}) bool

+ func (this *DescribeTableRequest) GoString() string

+ func (this *DescribeTableRequest) String() string

+ type DescribeTableResponse struct

+ Desc *TableDesc

+ IsActive bool

+ func (*DescribeTableResponse) Descriptor() ([]byte, []int)

+ func (*DescribeTableResponse) ProtoMessage()

+ func (m *DescribeTableResponse) GetDesc() *TableDesc

+ func (m *DescribeTableResponse) GetIsActive() bool

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

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

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

+ func (m *DescribeTableResponse) Reset()

+ func (m *DescribeTableResponse) Size() (n int)

+ func (m *DescribeTableResponse) Unmarshal(dAtA []byte) error

+ func (m *DescribeTableResponse) XXX_DiscardUnknown()

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

+ func (m *DescribeTableResponse) XXX_Merge(src proto.Message)

+ func (m *DescribeTableResponse) XXX_Size() int

+ func (m *DescribeTableResponse) XXX_Unmarshal(b []byte) error

+ func (this *DescribeTableResponse) Equal(that interface{}) bool

+ func (this *DescribeTableResponse) GoString() string

+ func (this *DescribeTableResponse) String() string

+ type GetChunksRequest struct

+ Chunks []*Chunk

+ func (*GetChunksRequest) Descriptor() ([]byte, []int)

+ func (*GetChunksRequest) ProtoMessage()

+ func (m *GetChunksRequest) GetChunks() []*Chunk

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

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

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

+ func (m *GetChunksRequest) Reset()

+ func (m *GetChunksRequest) Size() (n int)

+ func (m *GetChunksRequest) Unmarshal(dAtA []byte) error

+ func (m *GetChunksRequest) XXX_DiscardUnknown()

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

+ func (m *GetChunksRequest) XXX_Merge(src proto.Message)

+ func (m *GetChunksRequest) XXX_Size() int

+ func (m *GetChunksRequest) XXX_Unmarshal(b []byte) error

+ func (this *GetChunksRequest) Equal(that interface{}) bool

+ func (this *GetChunksRequest) GoString() string

+ func (this *GetChunksRequest) String() string

+ type GetChunksResponse struct

+ Chunks []*Chunk

+ func (*GetChunksResponse) Descriptor() ([]byte, []int)

+ func (*GetChunksResponse) ProtoMessage()

+ func (m *GetChunksResponse) GetChunks() []*Chunk

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

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

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

+ func (m *GetChunksResponse) Reset()

+ func (m *GetChunksResponse) Size() (n int)

+ func (m *GetChunksResponse) Unmarshal(dAtA []byte) error

+ func (m *GetChunksResponse) XXX_DiscardUnknown()

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

+ func (m *GetChunksResponse) XXX_Merge(src proto.Message)

+ func (m *GetChunksResponse) XXX_Size() int

+ func (m *GetChunksResponse) XXX_Unmarshal(b []byte) error

+ func (this *GetChunksResponse) Equal(that interface{}) bool

+ func (this *GetChunksResponse) GoString() string

+ func (this *GetChunksResponse) String() string

+ type GrpcStoreClient interface

+ CreateTable func(ctx context.Context, in *CreateTableRequest, opts ...grpc.CallOption) (*empty.Empty, error)

+ DeleteChunks func(ctx context.Context, in *ChunkID, opts ...grpc.CallOption) (*empty.Empty, error)

+ DeleteIndex func(ctx context.Context, in *DeleteIndexRequest, opts ...grpc.CallOption) (*empty.Empty, error)

+ DeleteTable func(ctx context.Context, in *DeleteTableRequest, opts ...grpc.CallOption) (*empty.Empty, error)

+ DescribeTable func(ctx context.Context, in *DescribeTableRequest, opts ...grpc.CallOption) (*DescribeTableResponse, error)

+ GetChunks func(ctx context.Context, in *GetChunksRequest, opts ...grpc.CallOption) (GrpcStore_GetChunksClient, error)

+ ListTables func(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ListTablesResponse, error)

+ PutChunks func(ctx context.Context, in *PutChunksRequest, opts ...grpc.CallOption) (*empty.Empty, error)

+ QueryIndex func(ctx context.Context, in *QueryIndexRequest, opts ...grpc.CallOption) (GrpcStore_QueryIndexClient, error)

+ UpdateTable func(ctx context.Context, in *UpdateTableRequest, opts ...grpc.CallOption) (*empty.Empty, error)

+ WriteIndex func(ctx context.Context, in *WriteIndexRequest, opts ...grpc.CallOption) (*empty.Empty, error)

+ func NewGrpcStoreClient(cc *grpc.ClientConn) GrpcStoreClient

+ type GrpcStoreServer interface

+ CreateTable func(context.Context, *CreateTableRequest) (*empty.Empty, error)

+ DeleteChunks func(context.Context, *ChunkID) (*empty.Empty, error)

+ DeleteIndex func(context.Context, *DeleteIndexRequest) (*empty.Empty, error)

+ DeleteTable func(context.Context, *DeleteTableRequest) (*empty.Empty, error)

+ DescribeTable func(context.Context, *DescribeTableRequest) (*DescribeTableResponse, error)

+ GetChunks func(*GetChunksRequest, GrpcStore_GetChunksServer) error

+ ListTables func(context.Context, *empty.Empty) (*ListTablesResponse, error)

+ PutChunks func(context.Context, *PutChunksRequest) (*empty.Empty, error)

+ QueryIndex func(*QueryIndexRequest, GrpcStore_QueryIndexServer) error

+ UpdateTable func(context.Context, *UpdateTableRequest) (*empty.Empty, error)

+ WriteIndex func(context.Context, *WriteIndexRequest) (*empty.Empty, error)

+ type GrpcStore_GetChunksClient interface

+ Recv func() (*GetChunksResponse, error)

+ type GrpcStore_GetChunksServer interface

+ Send func(*GetChunksResponse) error

+ type GrpcStore_QueryIndexClient interface

+ Recv func() (*QueryIndexResponse, error)

+ type GrpcStore_QueryIndexServer interface

+ Send func(*QueryIndexResponse) error

+ type IndexEntry struct

+ HashValue string

+ RangeValue []byte

+ TableName string

+ Value []byte

+ func (*IndexEntry) Descriptor() ([]byte, []int)

+ func (*IndexEntry) ProtoMessage()

+ func (m *IndexEntry) GetHashValue() string

+ func (m *IndexEntry) GetRangeValue() []byte

+ func (m *IndexEntry) GetTableName() string

+ func (m *IndexEntry) GetValue() []byte

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

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

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

+ func (m *IndexEntry) Reset()

+ func (m *IndexEntry) Size() (n int)

+ func (m *IndexEntry) Unmarshal(dAtA []byte) error

+ func (m *IndexEntry) XXX_DiscardUnknown()

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

+ func (m *IndexEntry) XXX_Merge(src proto.Message)

+ func (m *IndexEntry) XXX_Size() int

+ func (m *IndexEntry) XXX_Unmarshal(b []byte) error

+ func (this *IndexEntry) Equal(that interface{}) bool

+ func (this *IndexEntry) GoString() string

+ func (this *IndexEntry) String() string

+ type Labels struct

+ Name string

+ Value string

+ func (*Labels) Descriptor() ([]byte, []int)

+ func (*Labels) ProtoMessage()

+ func (m *Labels) GetName() string

+ func (m *Labels) GetValue() string

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

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

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

+ func (m *Labels) Reset()

+ func (m *Labels) Size() (n int)

+ func (m *Labels) Unmarshal(dAtA []byte) error

+ func (m *Labels) XXX_DiscardUnknown()

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

+ func (m *Labels) XXX_Merge(src proto.Message)

+ func (m *Labels) XXX_Size() int

+ func (m *Labels) XXX_Unmarshal(b []byte) error

+ func (this *Labels) Equal(that interface{}) bool

+ func (this *Labels) GoString() string

+ func (this *Labels) String() string

+ type ListTablesResponse struct

+ TableNames []string

+ func (*ListTablesResponse) Descriptor() ([]byte, []int)

+ func (*ListTablesResponse) ProtoMessage()

+ func (m *ListTablesResponse) GetTableNames() []string

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

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

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

+ func (m *ListTablesResponse) Reset()

+ func (m *ListTablesResponse) Size() (n int)

+ func (m *ListTablesResponse) Unmarshal(dAtA []byte) error

+ func (m *ListTablesResponse) XXX_DiscardUnknown()

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

+ func (m *ListTablesResponse) XXX_Merge(src proto.Message)

+ func (m *ListTablesResponse) XXX_Size() int

+ func (m *ListTablesResponse) XXX_Unmarshal(b []byte) error

+ func (this *ListTablesResponse) Equal(that interface{}) bool

+ func (this *ListTablesResponse) GoString() string

+ func (this *ListTablesResponse) String() string

+ type PutChunksRequest struct

+ Chunks []*Chunk

+ func (*PutChunksRequest) Descriptor() ([]byte, []int)

+ func (*PutChunksRequest) ProtoMessage()

+ func (m *PutChunksRequest) GetChunks() []*Chunk

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

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

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

+ func (m *PutChunksRequest) Reset()

+ func (m *PutChunksRequest) Size() (n int)

+ func (m *PutChunksRequest) Unmarshal(dAtA []byte) error

+ func (m *PutChunksRequest) XXX_DiscardUnknown()

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

+ func (m *PutChunksRequest) XXX_Merge(src proto.Message)

+ func (m *PutChunksRequest) XXX_Size() int

+ func (m *PutChunksRequest) XXX_Unmarshal(b []byte) error

+ func (this *PutChunksRequest) Equal(that interface{}) bool

+ func (this *PutChunksRequest) GoString() string

+ func (this *PutChunksRequest) String() string

+ type QueryIndexRequest struct

+ HashValue string

+ Immutable bool

+ RangeValuePrefix []byte

+ RangeValueStart []byte

+ TableName string

+ ValueEqual []byte

+ func (*QueryIndexRequest) Descriptor() ([]byte, []int)

+ func (*QueryIndexRequest) ProtoMessage()

+ func (m *QueryIndexRequest) GetHashValue() string

+ func (m *QueryIndexRequest) GetImmutable() bool

+ func (m *QueryIndexRequest) GetRangeValuePrefix() []byte

+ func (m *QueryIndexRequest) GetRangeValueStart() []byte

+ func (m *QueryIndexRequest) GetTableName() string

+ func (m *QueryIndexRequest) GetValueEqual() []byte

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

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

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

+ func (m *QueryIndexRequest) Reset()

+ func (m *QueryIndexRequest) Size() (n int)

+ func (m *QueryIndexRequest) Unmarshal(dAtA []byte) error

+ func (m *QueryIndexRequest) XXX_DiscardUnknown()

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

+ func (m *QueryIndexRequest) XXX_Merge(src proto.Message)

+ func (m *QueryIndexRequest) XXX_Size() int

+ func (m *QueryIndexRequest) XXX_Unmarshal(b []byte) error

+ func (this *QueryIndexRequest) Equal(that interface{}) bool

+ func (this *QueryIndexRequest) GoString() string

+ func (this *QueryIndexRequest) String() string

+ type QueryIndexResponse struct

+ Rows []*Row

+ func (*QueryIndexResponse) Descriptor() ([]byte, []int)

+ func (*QueryIndexResponse) ProtoMessage()

+ func (m *QueryIndexResponse) GetRows() []*Row

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

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

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

+ func (m *QueryIndexResponse) Reset()

+ func (m *QueryIndexResponse) Size() (n int)

+ func (m *QueryIndexResponse) Unmarshal(dAtA []byte) error

+ func (m *QueryIndexResponse) XXX_DiscardUnknown()

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

+ func (m *QueryIndexResponse) XXX_Merge(src proto.Message)

+ func (m *QueryIndexResponse) XXX_Size() int

+ func (m *QueryIndexResponse) XXX_Unmarshal(b []byte) error

+ func (r *QueryIndexResponse) Iterator() chunk.ReadBatchIterator

+ func (this *QueryIndexResponse) Equal(that interface{}) bool

+ func (this *QueryIndexResponse) GoString() string

+ func (this *QueryIndexResponse) String() string

+ type Row struct

+ RangeValue []byte

+ Value []byte

+ func (*Row) Descriptor() ([]byte, []int)

+ func (*Row) ProtoMessage()

+ func (m *Row) GetRangeValue() []byte

+ func (m *Row) GetValue() []byte

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

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

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

+ func (m *Row) Reset()

+ func (m *Row) Size() (n int)

+ func (m *Row) Unmarshal(dAtA []byte) error

+ func (m *Row) XXX_DiscardUnknown()

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

+ func (m *Row) XXX_Merge(src proto.Message)

+ func (m *Row) XXX_Size() int

+ func (m *Row) XXX_Unmarshal(b []byte) error

+ func (this *Row) Equal(that interface{}) bool

+ func (this *Row) GoString() string

+ func (this *Row) String() string

+ type StorageClient struct

+ func NewStorageClient(cfg Config, schemaCfg chunk.SchemaConfig) (*StorageClient, error)

+ func (s *StorageClient) BatchWrite(c context.Context, batch chunk.WriteBatch) error

+ func (s *StorageClient) DeleteChunk(ctx context.Context, chunkID string) error

+ func (s *StorageClient) GetChunks(ctx context.Context, input []chunk.Chunk) ([]chunk.Chunk, error)

+ func (s *StorageClient) NewWriteBatch() chunk.WriteBatch

+ func (s *StorageClient) PutChunks(ctx context.Context, chunks []chunk.Chunk) error

+ func (s *StorageClient) QueryPages(ctx context.Context, queries []chunk.IndexQuery, ...) error

+ func (s *StorageClient) Stop()

+ type TableClient struct

+ func NewTableClient(cfg Config) (*TableClient, error)

+ func (c *TableClient) CreateTable(ctx context.Context, desc chunk.TableDesc) error

+ func (c *TableClient) DeleteTable(ctx context.Context, name string) error

+ func (c *TableClient) DescribeTable(ctx context.Context, name string) (desc chunk.TableDesc, isActive bool, err error)

+ func (c *TableClient) ListTables(ctx context.Context) ([]string, error)

+ func (c *TableClient) Stop()

+ func (c *TableClient) UpdateTable(ctx context.Context, current, expected chunk.TableDesc) error

+ type TableDesc struct

+ Name string

+ ProvisionedRead int64

+ ProvisionedWrite int64

+ Tags map[string]string

+ UseOnDemandIOMode bool

+ func (*TableDesc) Descriptor() ([]byte, []int)

+ func (*TableDesc) ProtoMessage()

+ func (m *TableDesc) GetName() string

+ func (m *TableDesc) GetProvisionedRead() int64

+ func (m *TableDesc) GetProvisionedWrite() int64

+ func (m *TableDesc) GetTags() map[string]string

+ func (m *TableDesc) GetUseOnDemandIOMode() bool

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

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

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

+ func (m *TableDesc) Reset()

+ func (m *TableDesc) Size() (n int)

+ func (m *TableDesc) Unmarshal(dAtA []byte) error

+ func (m *TableDesc) XXX_DiscardUnknown()

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

+ func (m *TableDesc) XXX_Merge(src proto.Message)

+ func (m *TableDesc) XXX_Size() int

+ func (m *TableDesc) XXX_Unmarshal(b []byte) error

+ func (this *TableDesc) Equal(that interface{}) bool

+ func (this *TableDesc) GoString() string

+ func (this *TableDesc) String() string

+ type UnimplementedGrpcStoreServer struct

+ func (*UnimplementedGrpcStoreServer) CreateTable(ctx context.Context, req *CreateTableRequest) (*empty.Empty, error)

+ func (*UnimplementedGrpcStoreServer) DeleteChunks(ctx context.Context, req *ChunkID) (*empty.Empty, error)

+ func (*UnimplementedGrpcStoreServer) DeleteIndex(ctx context.Context, req *DeleteIndexRequest) (*empty.Empty, error)

+ func (*UnimplementedGrpcStoreServer) DeleteTable(ctx context.Context, req *DeleteTableRequest) (*empty.Empty, error)

+ func (*UnimplementedGrpcStoreServer) DescribeTable(ctx context.Context, req *DescribeTableRequest) (*DescribeTableResponse, error)

+ func (*UnimplementedGrpcStoreServer) GetChunks(req *GetChunksRequest, srv GrpcStore_GetChunksServer) error

+ func (*UnimplementedGrpcStoreServer) ListTables(ctx context.Context, req *empty.Empty) (*ListTablesResponse, error)

+ func (*UnimplementedGrpcStoreServer) PutChunks(ctx context.Context, req *PutChunksRequest) (*empty.Empty, error)

+ func (*UnimplementedGrpcStoreServer) QueryIndex(req *QueryIndexRequest, srv GrpcStore_QueryIndexServer) error

+ func (*UnimplementedGrpcStoreServer) UpdateTable(ctx context.Context, req *UpdateTableRequest) (*empty.Empty, error)

+ func (*UnimplementedGrpcStoreServer) WriteIndex(ctx context.Context, req *WriteIndexRequest) (*empty.Empty, error)

+ type UpdateTableRequest struct

+ Current *TableDesc

+ Expected *TableDesc

+ func (*UpdateTableRequest) Descriptor() ([]byte, []int)

+ func (*UpdateTableRequest) ProtoMessage()

+ func (m *UpdateTableRequest) GetCurrent() *TableDesc

+ func (m *UpdateTableRequest) GetExpected() *TableDesc

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

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

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

+ func (m *UpdateTableRequest) Reset()

+ func (m *UpdateTableRequest) Size() (n int)

+ func (m *UpdateTableRequest) Unmarshal(dAtA []byte) error

+ func (m *UpdateTableRequest) XXX_DiscardUnknown()

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

+ func (m *UpdateTableRequest) XXX_Merge(src proto.Message)

+ func (m *UpdateTableRequest) XXX_Size() int

+ func (m *UpdateTableRequest) XXX_Unmarshal(b []byte) error

+ func (this *UpdateTableRequest) Equal(that interface{}) bool

+ func (this *UpdateTableRequest) GoString() string

+ func (this *UpdateTableRequest) String() string

+ type WriteBatch struct

+ Deletes []*IndexEntry

+ Writes []*IndexEntry

+ func (*WriteBatch) Descriptor() ([]byte, []int)

+ func (*WriteBatch) ProtoMessage()

+ func (m *WriteBatch) GetDeletes() []*IndexEntry

+ func (m *WriteBatch) GetWrites() []*IndexEntry

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

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

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

+ func (m *WriteBatch) Reset()

+ func (m *WriteBatch) Size() (n int)

+ func (m *WriteBatch) Unmarshal(dAtA []byte) error

+ func (m *WriteBatch) XXX_DiscardUnknown()

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

+ func (m *WriteBatch) XXX_Merge(src proto.Message)

+ func (m *WriteBatch) XXX_Size() int

+ func (m *WriteBatch) XXX_Unmarshal(b []byte) error

+ func (this *WriteBatch) Equal(that interface{}) bool

+ func (this *WriteBatch) GoString() string

+ func (this *WriteBatch) String() string

+ func (w *WriteBatch) Add(tableName, hashValue string, rangeValue []byte, value []byte)

+ func (w *WriteBatch) Delete(tableName, hashValue string, rangeValue []byte)

+ type WriteIndexRequest struct

+ Writes []*IndexEntry

+ func (*WriteIndexRequest) Descriptor() ([]byte, []int)

+ func (*WriteIndexRequest) ProtoMessage()

+ func (m *WriteIndexRequest) GetWrites() []*IndexEntry

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

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

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

+ func (m *WriteIndexRequest) Reset()

+ func (m *WriteIndexRequest) Size() (n int)

+ func (m *WriteIndexRequest) Unmarshal(dAtA []byte) error

+ func (m *WriteIndexRequest) XXX_DiscardUnknown()

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

+ func (m *WriteIndexRequest) XXX_Merge(src proto.Message)

+ func (m *WriteIndexRequest) XXX_Size() int

+ func (m *WriteIndexRequest) XXX_Unmarshal(b []byte) error

+ func (this *WriteIndexRequest) Equal(that interface{}) bool

+ func (this *WriteIndexRequest) GoString() string

+ func (this *WriteIndexRequest) String() string

Jun 26, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Jun 24, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex