Documentation ¶
Index ¶
- Variables
- func NewGrpcMatchstore(addresses []string, serverPort int, capacity uint16, ...) (matches.Matchstore, error)
- func RegisterMatchstoreServer(s grpc.ServiceRegistrar, srv MatchstoreServer)
- type ActualRequest
- func (*ActualRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ActualRequest) GetHeader() map[string]*HeaderValue
- func (x *ActualRequest) GetHost() string
- func (x *ActualRequest) GetMethod() string
- func (x *ActualRequest) GetUrl() string
- func (*ActualRequest) ProtoMessage()
- func (x *ActualRequest) ProtoReflect() protoreflect.Message
- func (x *ActualRequest) Reset()
- func (x *ActualRequest) String() string
- type ActualResponse
- func (*ActualResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ActualResponse) GetHeader() map[string]*HeaderValue
- func (x *ActualResponse) GetStatusCode() int32
- func (*ActualResponse) ProtoMessage()
- func (x *ActualResponse) ProtoReflect() protoreflect.Message
- func (x *ActualResponse) Reset()
- func (x *ActualResponse) String() string
- type AddAllResponse
- type EndPointRequest
- type HeaderValue
- type Match
- func (*Match) Descriptor() ([]byte, []int)deprecated
- func (x *Match) GetActualRequest() *ActualRequest
- func (x *Match) GetActualResponse() *ActualResponse
- func (x *Match) GetEndpointId() string
- func (x *Match) GetTimestamp() *timestamppb.Timestamp
- func (*Match) ProtoMessage()
- func (x *Match) ProtoReflect() protoreflect.Message
- func (x *Match) Reset()
- func (x *Match) String() string
- type MatchesCountResponse
- func (*MatchesCountResponse) Descriptor() ([]byte, []int)deprecated
- func (x *MatchesCountResponse) GetMatchesCount() uint64
- func (*MatchesCountResponse) ProtoMessage()
- func (x *MatchesCountResponse) ProtoReflect() protoreflect.Message
- func (x *MatchesCountResponse) Reset()
- func (x *MatchesCountResponse) String() string
- type MatchesResponse
- type MatchstoreClient
- type MatchstoreServer
- type Mismatch
- func (*Mismatch) Descriptor() ([]byte, []int)deprecated
- func (x *Mismatch) GetActualRequest() *ActualRequest
- func (x *Mismatch) GetMismatchDetails() string
- func (x *Mismatch) GetTimestamp() *timestamppb.Timestamp
- func (*Mismatch) ProtoMessage()
- func (x *Mismatch) ProtoReflect() protoreflect.Message
- func (x *Mismatch) Reset()
- func (x *Mismatch) String() string
- type MismatchRequest
- type MismatchesCountResponse
- func (*MismatchesCountResponse) Descriptor() ([]byte, []int)deprecated
- func (x *MismatchesCountResponse) GetMismatchesCount() uint64
- func (*MismatchesCountResponse) ProtoMessage()
- func (x *MismatchesCountResponse) ProtoReflect() protoreflect.Message
- func (x *MismatchesCountResponse) Reset()
- func (x *MismatchesCountResponse) String() string
- type MismatchesResponse
- func (*MismatchesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *MismatchesResponse) GetMismatches() []*Mismatch
- func (*MismatchesResponse) ProtoMessage()
- func (x *MismatchesResponse) ProtoReflect() protoreflect.Message
- func (x *MismatchesResponse) Reset()
- func (x *MismatchesResponse) String() string
- type RemoveResponse
- type UnimplementedMatchstoreServer
- 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
Constants ¶
This section is empty.
Variables ¶
var File_matchstore_matchstore_proto protoreflect.FileDescriptor
var Matchstore_ServiceDesc = grpc.ServiceDesc{ ServiceName: "matchstore.Matchstore", HandlerType: (*MatchstoreServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "FetchMatches", Handler: _Matchstore_FetchMatches_Handler, }, { MethodName: "FetchMismatches", Handler: _Matchstore_FetchMismatches_Handler, }, { MethodName: "FetchMatchesCount", Handler: _Matchstore_FetchMatchesCount_Handler, }, { MethodName: "FetchMismatchesCount", Handler: _Matchstore_FetchMismatchesCount_Handler, }, { MethodName: "RemoveMatches", Handler: _Matchstore_RemoveMatches_Handler, }, { MethodName: "RemoveMismatches", Handler: _Matchstore_RemoveMismatches_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "matchstore/matchstore.proto", }
Matchstore_ServiceDesc is the grpc.ServiceDesc for Matchstore service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func NewGrpcMatchstore ¶
func NewGrpcMatchstore(addresses []string, serverPort int, capacity uint16, logger *logging.LoggerUtil) (matches.Matchstore, error)
NewGrpcMatchstore creates a new distributed matches.Matchstore
func RegisterMatchstoreServer ¶ added in v0.0.13
func RegisterMatchstoreServer(s grpc.ServiceRegistrar, srv MatchstoreServer)
Types ¶
type ActualRequest ¶ added in v0.0.13
type ActualRequest struct { Method string `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"` Url string `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"` Header map[string]*HeaderValue `` /* 153-byte string literal not displayed */ Host string `protobuf:"bytes,4,opt,name=host,proto3" json:"host,omitempty"` // contains filtered or unexported fields }
func (*ActualRequest) Descriptor
deprecated
added in
v0.0.13
func (*ActualRequest) Descriptor() ([]byte, []int)
Deprecated: Use ActualRequest.ProtoReflect.Descriptor instead.
func (*ActualRequest) GetHeader ¶ added in v0.0.13
func (x *ActualRequest) GetHeader() map[string]*HeaderValue
func (*ActualRequest) GetHost ¶ added in v0.0.13
func (x *ActualRequest) GetHost() string
func (*ActualRequest) GetMethod ¶ added in v0.0.13
func (x *ActualRequest) GetMethod() string
func (*ActualRequest) GetUrl ¶ added in v0.0.13
func (x *ActualRequest) GetUrl() string
func (*ActualRequest) ProtoMessage ¶ added in v0.0.13
func (*ActualRequest) ProtoMessage()
func (*ActualRequest) ProtoReflect ¶ added in v0.0.13
func (x *ActualRequest) ProtoReflect() protoreflect.Message
func (*ActualRequest) Reset ¶ added in v0.0.13
func (x *ActualRequest) Reset()
func (*ActualRequest) String ¶ added in v0.0.13
func (x *ActualRequest) String() string
type ActualResponse ¶ added in v0.0.13
type ActualResponse struct { StatusCode int32 `protobuf:"varint,1,opt,name=statusCode,proto3" json:"statusCode,omitempty"` Header map[string]*HeaderValue `` /* 153-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ActualResponse) Descriptor
deprecated
added in
v0.0.13
func (*ActualResponse) Descriptor() ([]byte, []int)
Deprecated: Use ActualResponse.ProtoReflect.Descriptor instead.
func (*ActualResponse) GetHeader ¶ added in v0.0.13
func (x *ActualResponse) GetHeader() map[string]*HeaderValue
func (*ActualResponse) GetStatusCode ¶ added in v0.0.13
func (x *ActualResponse) GetStatusCode() int32
func (*ActualResponse) ProtoMessage ¶ added in v0.0.13
func (*ActualResponse) ProtoMessage()
func (*ActualResponse) ProtoReflect ¶ added in v0.0.13
func (x *ActualResponse) ProtoReflect() protoreflect.Message
func (*ActualResponse) Reset ¶ added in v0.0.13
func (x *ActualResponse) Reset()
func (*ActualResponse) String ¶ added in v0.0.13
func (x *ActualResponse) String() string
type AddAllResponse ¶ added in v0.0.13
type AddAllResponse struct { Locked bool `protobuf:"varint,1,opt,name=locked,proto3" json:"locked,omitempty"` // contains filtered or unexported fields }
func (*AddAllResponse) Descriptor
deprecated
added in
v0.0.13
func (*AddAllResponse) Descriptor() ([]byte, []int)
Deprecated: Use AddAllResponse.ProtoReflect.Descriptor instead.
func (*AddAllResponse) GetLocked ¶ added in v0.0.13
func (x *AddAllResponse) GetLocked() bool
func (*AddAllResponse) ProtoMessage ¶ added in v0.0.13
func (*AddAllResponse) ProtoMessage()
func (*AddAllResponse) ProtoReflect ¶ added in v0.0.13
func (x *AddAllResponse) ProtoReflect() protoreflect.Message
func (*AddAllResponse) Reset ¶ added in v0.0.13
func (x *AddAllResponse) Reset()
func (*AddAllResponse) String ¶ added in v0.0.13
func (x *AddAllResponse) String() string
type EndPointRequest ¶ added in v0.0.13
type EndPointRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*EndPointRequest) Descriptor
deprecated
added in
v0.0.13
func (*EndPointRequest) Descriptor() ([]byte, []int)
Deprecated: Use EndPointRequest.ProtoReflect.Descriptor instead.
func (*EndPointRequest) GetId ¶ added in v0.0.13
func (x *EndPointRequest) GetId() string
func (*EndPointRequest) ProtoMessage ¶ added in v0.0.13
func (*EndPointRequest) ProtoMessage()
func (*EndPointRequest) ProtoReflect ¶ added in v0.0.13
func (x *EndPointRequest) ProtoReflect() protoreflect.Message
func (*EndPointRequest) Reset ¶ added in v0.0.13
func (x *EndPointRequest) Reset()
func (*EndPointRequest) String ¶ added in v0.0.13
func (x *EndPointRequest) String() string
type HeaderValue ¶ added in v0.0.13
type HeaderValue struct { Val []string `protobuf:"bytes,1,rep,name=val,proto3" json:"val,omitempty"` // contains filtered or unexported fields }
func (*HeaderValue) Descriptor
deprecated
added in
v0.0.13
func (*HeaderValue) Descriptor() ([]byte, []int)
Deprecated: Use HeaderValue.ProtoReflect.Descriptor instead.
func (*HeaderValue) GetVal ¶ added in v0.0.13
func (x *HeaderValue) GetVal() []string
func (*HeaderValue) ProtoMessage ¶ added in v0.0.13
func (*HeaderValue) ProtoMessage()
func (*HeaderValue) ProtoReflect ¶ added in v0.0.13
func (x *HeaderValue) ProtoReflect() protoreflect.Message
func (*HeaderValue) Reset ¶ added in v0.0.13
func (x *HeaderValue) Reset()
func (*HeaderValue) String ¶ added in v0.0.13
func (x *HeaderValue) String() string
type Match ¶ added in v0.0.13
type Match struct { EndpointId string `protobuf:"bytes,1,opt,name=endpointId,proto3" json:"endpointId,omitempty"` Timestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"` ActualRequest *ActualRequest `protobuf:"bytes,3,opt,name=actualRequest,proto3" json:"actualRequest,omitempty"` ActualResponse *ActualResponse `protobuf:"bytes,4,opt,name=actualResponse,proto3" json:"actualResponse,omitempty"` // contains filtered or unexported fields }
func (*Match) Descriptor
deprecated
added in
v0.0.13
func (*Match) GetActualRequest ¶ added in v0.0.13
func (x *Match) GetActualRequest() *ActualRequest
func (*Match) GetActualResponse ¶ added in v0.0.13
func (x *Match) GetActualResponse() *ActualResponse
func (*Match) GetEndpointId ¶ added in v0.0.13
func (*Match) GetTimestamp ¶ added in v0.0.13
func (x *Match) GetTimestamp() *timestamppb.Timestamp
func (*Match) ProtoMessage ¶ added in v0.0.13
func (*Match) ProtoMessage()
func (*Match) ProtoReflect ¶ added in v0.0.13
func (x *Match) ProtoReflect() protoreflect.Message
type MatchesCountResponse ¶ added in v0.0.13
type MatchesCountResponse struct { MatchesCount uint64 `protobuf:"varint,1,opt,name=matchesCount,proto3" json:"matchesCount,omitempty"` // contains filtered or unexported fields }
func (*MatchesCountResponse) Descriptor
deprecated
added in
v0.0.13
func (*MatchesCountResponse) Descriptor() ([]byte, []int)
Deprecated: Use MatchesCountResponse.ProtoReflect.Descriptor instead.
func (*MatchesCountResponse) GetMatchesCount ¶ added in v0.0.13
func (x *MatchesCountResponse) GetMatchesCount() uint64
func (*MatchesCountResponse) ProtoMessage ¶ added in v0.0.13
func (*MatchesCountResponse) ProtoMessage()
func (*MatchesCountResponse) ProtoReflect ¶ added in v0.0.13
func (x *MatchesCountResponse) ProtoReflect() protoreflect.Message
func (*MatchesCountResponse) Reset ¶ added in v0.0.13
func (x *MatchesCountResponse) Reset()
func (*MatchesCountResponse) String ¶ added in v0.0.13
func (x *MatchesCountResponse) String() string
type MatchesResponse ¶ added in v0.0.13
type MatchesResponse struct { Matches []*Match `protobuf:"bytes,1,rep,name=matches,proto3" json:"matches,omitempty"` // contains filtered or unexported fields }
func (*MatchesResponse) Descriptor
deprecated
added in
v0.0.13
func (*MatchesResponse) Descriptor() ([]byte, []int)
Deprecated: Use MatchesResponse.ProtoReflect.Descriptor instead.
func (*MatchesResponse) GetMatches ¶ added in v0.0.13
func (x *MatchesResponse) GetMatches() []*Match
func (*MatchesResponse) ProtoMessage ¶ added in v0.0.13
func (*MatchesResponse) ProtoMessage()
func (*MatchesResponse) ProtoReflect ¶ added in v0.0.13
func (x *MatchesResponse) ProtoReflect() protoreflect.Message
func (*MatchesResponse) Reset ¶ added in v0.0.13
func (x *MatchesResponse) Reset()
func (*MatchesResponse) String ¶ added in v0.0.13
func (x *MatchesResponse) String() string
type MatchstoreClient ¶ added in v0.0.13
type MatchstoreClient interface { FetchMatches(ctx context.Context, in *EndPointRequest, opts ...grpc.CallOption) (*MatchesResponse, error) FetchMismatches(ctx context.Context, in *MismatchRequest, opts ...grpc.CallOption) (*MismatchesResponse, error) FetchMatchesCount(ctx context.Context, in *EndPointRequest, opts ...grpc.CallOption) (*MatchesCountResponse, error) FetchMismatchesCount(ctx context.Context, in *MismatchRequest, opts ...grpc.CallOption) (*MismatchesCountResponse, error) RemoveMatches(ctx context.Context, in *EndPointRequest, opts ...grpc.CallOption) (*RemoveResponse, error) RemoveMismatches(ctx context.Context, in *MismatchRequest, opts ...grpc.CallOption) (*RemoveResponse, error) }
MatchstoreClient is the client API for Matchstore service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewMatchstoreClient ¶ added in v0.0.13
func NewMatchstoreClient(cc grpc.ClientConnInterface) MatchstoreClient
type MatchstoreServer ¶ added in v0.0.13
type MatchstoreServer interface { FetchMatches(context.Context, *EndPointRequest) (*MatchesResponse, error) FetchMismatches(context.Context, *MismatchRequest) (*MismatchesResponse, error) FetchMatchesCount(context.Context, *EndPointRequest) (*MatchesCountResponse, error) FetchMismatchesCount(context.Context, *MismatchRequest) (*MismatchesCountResponse, error) RemoveMatches(context.Context, *EndPointRequest) (*RemoveResponse, error) RemoveMismatches(context.Context, *MismatchRequest) (*RemoveResponse, error) // contains filtered or unexported methods }
MatchstoreServer is the server API for Matchstore service. All implementations must embed UnimplementedMatchstoreServer for forward compatibility
type Mismatch ¶ added in v0.0.13
type Mismatch struct { MismatchDetails string `protobuf:"bytes,1,opt,name=mismatchDetails,proto3" json:"mismatchDetails,omitempty"` Timestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"` ActualRequest *ActualRequest `protobuf:"bytes,3,opt,name=actualRequest,proto3" json:"actualRequest,omitempty"` // contains filtered or unexported fields }
func (*Mismatch) Descriptor
deprecated
added in
v0.0.13
func (*Mismatch) GetActualRequest ¶ added in v0.0.13
func (x *Mismatch) GetActualRequest() *ActualRequest
func (*Mismatch) GetMismatchDetails ¶ added in v0.0.13
func (*Mismatch) GetTimestamp ¶ added in v0.0.13
func (x *Mismatch) GetTimestamp() *timestamppb.Timestamp
func (*Mismatch) ProtoMessage ¶ added in v0.0.13
func (*Mismatch) ProtoMessage()
func (*Mismatch) ProtoReflect ¶ added in v0.0.13
func (x *Mismatch) ProtoReflect() protoreflect.Message
type MismatchRequest ¶ added in v0.0.13
type MismatchRequest struct {
// contains filtered or unexported fields
}
func (*MismatchRequest) Descriptor
deprecated
added in
v0.0.13
func (*MismatchRequest) Descriptor() ([]byte, []int)
Deprecated: Use MismatchRequest.ProtoReflect.Descriptor instead.
func (*MismatchRequest) ProtoMessage ¶ added in v0.0.13
func (*MismatchRequest) ProtoMessage()
func (*MismatchRequest) ProtoReflect ¶ added in v0.0.13
func (x *MismatchRequest) ProtoReflect() protoreflect.Message
func (*MismatchRequest) Reset ¶ added in v0.0.13
func (x *MismatchRequest) Reset()
func (*MismatchRequest) String ¶ added in v0.0.13
func (x *MismatchRequest) String() string
type MismatchesCountResponse ¶ added in v0.0.13
type MismatchesCountResponse struct { MismatchesCount uint64 `protobuf:"varint,1,opt,name=mismatchesCount,proto3" json:"mismatchesCount,omitempty"` // contains filtered or unexported fields }
func (*MismatchesCountResponse) Descriptor
deprecated
added in
v0.0.13
func (*MismatchesCountResponse) Descriptor() ([]byte, []int)
Deprecated: Use MismatchesCountResponse.ProtoReflect.Descriptor instead.
func (*MismatchesCountResponse) GetMismatchesCount ¶ added in v0.0.13
func (x *MismatchesCountResponse) GetMismatchesCount() uint64
func (*MismatchesCountResponse) ProtoMessage ¶ added in v0.0.13
func (*MismatchesCountResponse) ProtoMessage()
func (*MismatchesCountResponse) ProtoReflect ¶ added in v0.0.13
func (x *MismatchesCountResponse) ProtoReflect() protoreflect.Message
func (*MismatchesCountResponse) Reset ¶ added in v0.0.13
func (x *MismatchesCountResponse) Reset()
func (*MismatchesCountResponse) String ¶ added in v0.0.13
func (x *MismatchesCountResponse) String() string
type MismatchesResponse ¶ added in v0.0.13
type MismatchesResponse struct { Mismatches []*Mismatch `protobuf:"bytes,1,rep,name=mismatches,proto3" json:"mismatches,omitempty"` // contains filtered or unexported fields }
func (*MismatchesResponse) Descriptor
deprecated
added in
v0.0.13
func (*MismatchesResponse) Descriptor() ([]byte, []int)
Deprecated: Use MismatchesResponse.ProtoReflect.Descriptor instead.
func (*MismatchesResponse) GetMismatches ¶ added in v0.0.13
func (x *MismatchesResponse) GetMismatches() []*Mismatch
func (*MismatchesResponse) ProtoMessage ¶ added in v0.0.13
func (*MismatchesResponse) ProtoMessage()
func (*MismatchesResponse) ProtoReflect ¶ added in v0.0.13
func (x *MismatchesResponse) ProtoReflect() protoreflect.Message
func (*MismatchesResponse) Reset ¶ added in v0.0.13
func (x *MismatchesResponse) Reset()
func (*MismatchesResponse) String ¶ added in v0.0.13
func (x *MismatchesResponse) String() string
type RemoveResponse ¶ added in v0.0.13
type RemoveResponse struct {
// contains filtered or unexported fields
}
func (*RemoveResponse) Descriptor
deprecated
added in
v0.0.13
func (*RemoveResponse) Descriptor() ([]byte, []int)
Deprecated: Use RemoveResponse.ProtoReflect.Descriptor instead.
func (*RemoveResponse) ProtoMessage ¶ added in v0.0.13
func (*RemoveResponse) ProtoMessage()
func (*RemoveResponse) ProtoReflect ¶ added in v0.0.13
func (x *RemoveResponse) ProtoReflect() protoreflect.Message
func (*RemoveResponse) Reset ¶ added in v0.0.13
func (x *RemoveResponse) Reset()
func (*RemoveResponse) String ¶ added in v0.0.13
func (x *RemoveResponse) String() string
type UnimplementedMatchstoreServer ¶ added in v0.0.13
type UnimplementedMatchstoreServer struct { }
UnimplementedMatchstoreServer must be embedded to have forward compatible implementations.
func (UnimplementedMatchstoreServer) FetchMatches ¶ added in v0.0.13
func (UnimplementedMatchstoreServer) FetchMatches(context.Context, *EndPointRequest) (*MatchesResponse, error)
func (UnimplementedMatchstoreServer) FetchMatchesCount ¶ added in v0.0.13
func (UnimplementedMatchstoreServer) FetchMatchesCount(context.Context, *EndPointRequest) (*MatchesCountResponse, error)
func (UnimplementedMatchstoreServer) FetchMismatches ¶ added in v0.0.13
func (UnimplementedMatchstoreServer) FetchMismatches(context.Context, *MismatchRequest) (*MismatchesResponse, error)
func (UnimplementedMatchstoreServer) FetchMismatchesCount ¶ added in v0.0.13
func (UnimplementedMatchstoreServer) FetchMismatchesCount(context.Context, *MismatchRequest) (*MismatchesCountResponse, error)
func (UnimplementedMatchstoreServer) RemoveMatches ¶ added in v0.0.13
func (UnimplementedMatchstoreServer) RemoveMatches(context.Context, *EndPointRequest) (*RemoveResponse, error)
func (UnimplementedMatchstoreServer) RemoveMismatches ¶ added in v0.0.13
func (UnimplementedMatchstoreServer) RemoveMismatches(context.Context, *MismatchRequest) (*RemoveResponse, error)
type UnsafeMatchstoreServer ¶ added in v0.0.13
type UnsafeMatchstoreServer interface {
// contains filtered or unexported methods
}
UnsafeMatchstoreServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MatchstoreServer will result in compilation errors.