Versions in this module Expand all Collapse all v1 v1.3.0 May 21, 2023 Changes in this version + var File_matchstore_matchstore_proto protoreflect.FileDescriptor + var Matchstore_ServiceDesc = grpc.ServiceDesc + func NewGrpcMatchstore(addresses []string, serverPort int, capacity uint16, logLevel string) (matches.Matchstore, error) + func RegisterMatchstoreServer(s grpc.ServiceRegistrar, srv MatchstoreServer) + type ActualRequest struct + Header map[string]*HeaderValue + Host string + Method string + Url string + func (*ActualRequest) Descriptor() ([]byte, []int) + func (*ActualRequest) ProtoMessage() + func (x *ActualRequest) GetHeader() map[string]*HeaderValue + func (x *ActualRequest) GetHost() string + func (x *ActualRequest) GetMethod() string + func (x *ActualRequest) GetUrl() string + func (x *ActualRequest) ProtoReflect() protoreflect.Message + func (x *ActualRequest) Reset() + func (x *ActualRequest) String() string + type ActualResponse struct + Header map[string]*HeaderValue + StatusCode int32 + func (*ActualResponse) Descriptor() ([]byte, []int) + func (*ActualResponse) ProtoMessage() + func (x *ActualResponse) GetHeader() map[string]*HeaderValue + func (x *ActualResponse) GetStatusCode() int32 + func (x *ActualResponse) ProtoReflect() protoreflect.Message + func (x *ActualResponse) Reset() + func (x *ActualResponse) String() string + type AddAllResponse struct + Locked bool + func (*AddAllResponse) Descriptor() ([]byte, []int) + func (*AddAllResponse) ProtoMessage() + func (x *AddAllResponse) GetLocked() bool + func (x *AddAllResponse) ProtoReflect() protoreflect.Message + func (x *AddAllResponse) Reset() + func (x *AddAllResponse) String() string + type EndPointRequest struct + Id string + func (*EndPointRequest) Descriptor() ([]byte, []int) + func (*EndPointRequest) ProtoMessage() + func (x *EndPointRequest) GetId() string + func (x *EndPointRequest) ProtoReflect() protoreflect.Message + func (x *EndPointRequest) Reset() + func (x *EndPointRequest) String() string + type HeaderValue struct + Val []string + func (*HeaderValue) Descriptor() ([]byte, []int) + func (*HeaderValue) ProtoMessage() + func (x *HeaderValue) GetVal() []string + func (x *HeaderValue) ProtoReflect() protoreflect.Message + func (x *HeaderValue) Reset() + func (x *HeaderValue) String() string + type Match struct + ActualRequest *ActualRequest + ActualResponse *ActualResponse + EndpointId string + Timestamp *timestamppb.Timestamp + func (*Match) Descriptor() ([]byte, []int) + func (*Match) ProtoMessage() + func (x *Match) GetActualRequest() *ActualRequest + func (x *Match) GetActualResponse() *ActualResponse + func (x *Match) GetEndpointId() string + func (x *Match) GetTimestamp() *timestamppb.Timestamp + func (x *Match) ProtoReflect() protoreflect.Message + func (x *Match) Reset() + func (x *Match) String() string + type MatchesCountResponse struct + MatchesCount uint64 + func (*MatchesCountResponse) Descriptor() ([]byte, []int) + func (*MatchesCountResponse) ProtoMessage() + func (x *MatchesCountResponse) GetMatchesCount() uint64 + func (x *MatchesCountResponse) ProtoReflect() protoreflect.Message + func (x *MatchesCountResponse) Reset() + func (x *MatchesCountResponse) String() string + type MatchesResponse struct + Matches []*Match + func (*MatchesResponse) Descriptor() ([]byte, []int) + func (*MatchesResponse) ProtoMessage() + func (x *MatchesResponse) GetMatches() []*Match + func (x *MatchesResponse) ProtoReflect() protoreflect.Message + func (x *MatchesResponse) Reset() + func (x *MatchesResponse) String() string + type MatchstoreClient interface + FetchMatches func(ctx context.Context, in *EndPointRequest, opts ...grpc.CallOption) (*MatchesResponse, error) + FetchMatchesCount func(ctx context.Context, in *EndPointRequest, opts ...grpc.CallOption) (*MatchesCountResponse, error) + FetchMismatches func(ctx context.Context, in *MismatchRequest, opts ...grpc.CallOption) (*MismatchesResponse, error) + FetchMismatchesCount func(ctx context.Context, in *MismatchRequest, opts ...grpc.CallOption) (*MismatchesCountResponse, error) + RemoveMatches func(ctx context.Context, in *EndPointRequest, opts ...grpc.CallOption) (*RemoveResponse, error) + RemoveMismatches func(ctx context.Context, in *MismatchRequest, opts ...grpc.CallOption) (*RemoveResponse, error) + func NewMatchstoreClient(cc grpc.ClientConnInterface) MatchstoreClient + type MatchstoreServer interface + FetchMatches func(context.Context, *EndPointRequest) (*MatchesResponse, error) + FetchMatchesCount func(context.Context, *EndPointRequest) (*MatchesCountResponse, error) + FetchMismatches func(context.Context, *MismatchRequest) (*MismatchesResponse, error) + FetchMismatchesCount func(context.Context, *MismatchRequest) (*MismatchesCountResponse, error) + RemoveMatches func(context.Context, *EndPointRequest) (*RemoveResponse, error) + RemoveMismatches func(context.Context, *MismatchRequest) (*RemoveResponse, error) + type Mismatch struct + ActualRequest *ActualRequest + MismatchDetails string + Timestamp *timestamppb.Timestamp + func (*Mismatch) Descriptor() ([]byte, []int) + func (*Mismatch) ProtoMessage() + func (x *Mismatch) GetActualRequest() *ActualRequest + func (x *Mismatch) GetMismatchDetails() string + func (x *Mismatch) GetTimestamp() *timestamppb.Timestamp + func (x *Mismatch) ProtoReflect() protoreflect.Message + func (x *Mismatch) Reset() + func (x *Mismatch) String() string + type MismatchRequest struct + func (*MismatchRequest) Descriptor() ([]byte, []int) + func (*MismatchRequest) ProtoMessage() + func (x *MismatchRequest) ProtoReflect() protoreflect.Message + func (x *MismatchRequest) Reset() + func (x *MismatchRequest) String() string + type MismatchesCountResponse struct + MismatchesCount uint64 + func (*MismatchesCountResponse) Descriptor() ([]byte, []int) + func (*MismatchesCountResponse) ProtoMessage() + func (x *MismatchesCountResponse) GetMismatchesCount() uint64 + func (x *MismatchesCountResponse) ProtoReflect() protoreflect.Message + func (x *MismatchesCountResponse) Reset() + func (x *MismatchesCountResponse) String() string + type MismatchesResponse struct + Mismatches []*Mismatch + func (*MismatchesResponse) Descriptor() ([]byte, []int) + func (*MismatchesResponse) ProtoMessage() + func (x *MismatchesResponse) GetMismatches() []*Mismatch + func (x *MismatchesResponse) ProtoReflect() protoreflect.Message + func (x *MismatchesResponse) Reset() + func (x *MismatchesResponse) String() string + type RemoveResponse struct + func (*RemoveResponse) Descriptor() ([]byte, []int) + func (*RemoveResponse) ProtoMessage() + func (x *RemoveResponse) ProtoReflect() protoreflect.Message + func (x *RemoveResponse) Reset() + func (x *RemoveResponse) String() string + type UnimplementedMatchstoreServer struct + func (UnimplementedMatchstoreServer) FetchMatches(context.Context, *EndPointRequest) (*MatchesResponse, error) + func (UnimplementedMatchstoreServer) FetchMatchesCount(context.Context, *EndPointRequest) (*MatchesCountResponse, error) + func (UnimplementedMatchstoreServer) FetchMismatches(context.Context, *MismatchRequest) (*MismatchesResponse, error) + func (UnimplementedMatchstoreServer) FetchMismatchesCount(context.Context, *MismatchRequest) (*MismatchesCountResponse, error) + func (UnimplementedMatchstoreServer) RemoveMatches(context.Context, *EndPointRequest) (*RemoveResponse, error) + func (UnimplementedMatchstoreServer) RemoveMismatches(context.Context, *MismatchRequest) (*RemoveResponse, error) + type UnsafeMatchstoreServer interface