Versions in this module Expand all Collapse all v0 v0.1.0 Jun 15, 2023 Changes in this version + var DeadlockRequestType_name = map[int32]string + var DeadlockRequestType_value = map[string]int32 + var ErrIntOverflowDeadlock = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthDeadlock = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupDeadlock = fmt.Errorf("proto: unexpected end of group") + func RegisterDeadlockServer(s *grpc.Server, srv DeadlockServer) + type DeadlockClient interface + Detect func(ctx context.Context, opts ...grpc.CallOption) (Deadlock_DetectClient, error) + GetWaitForEntries func(ctx context.Context, in *WaitForEntriesRequest, opts ...grpc.CallOption) (*WaitForEntriesResponse, error) + func NewDeadlockClient(cc *grpc.ClientConn) DeadlockClient + type DeadlockRequest struct + Entry WaitForEntry + Tp DeadlockRequestType + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeadlockRequest) Descriptor() ([]byte, []int) + func (*DeadlockRequest) ProtoMessage() + func (m *DeadlockRequest) GetEntry() WaitForEntry + func (m *DeadlockRequest) GetTp() DeadlockRequestType + func (m *DeadlockRequest) Marshal() (dAtA []byte, err error) + func (m *DeadlockRequest) MarshalTo(dAtA []byte) (int, error) + func (m *DeadlockRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DeadlockRequest) Reset() + func (m *DeadlockRequest) Size() (n int) + func (m *DeadlockRequest) String() string + func (m *DeadlockRequest) Unmarshal(dAtA []byte) error + func (m *DeadlockRequest) XXX_DiscardUnknown() + func (m *DeadlockRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeadlockRequest) XXX_Merge(src proto.Message) + func (m *DeadlockRequest) XXX_Size() int + func (m *DeadlockRequest) XXX_Unmarshal(b []byte) error + type DeadlockRequestType int32 + const DeadlockRequestType_CleanUp + const DeadlockRequestType_CleanUpWaitFor + const DeadlockRequestType_Detect + func (DeadlockRequestType) EnumDescriptor() ([]byte, []int) + func (x DeadlockRequestType) String() string + type DeadlockResponse struct + DeadlockKeyHash uint64 + Entry WaitForEntry + WaitChain []*WaitForEntry + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeadlockResponse) Descriptor() ([]byte, []int) + func (*DeadlockResponse) ProtoMessage() + func (m *DeadlockResponse) GetDeadlockKeyHash() uint64 + func (m *DeadlockResponse) GetEntry() WaitForEntry + func (m *DeadlockResponse) GetWaitChain() []*WaitForEntry + func (m *DeadlockResponse) Marshal() (dAtA []byte, err error) + func (m *DeadlockResponse) MarshalTo(dAtA []byte) (int, error) + func (m *DeadlockResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DeadlockResponse) Reset() + func (m *DeadlockResponse) Size() (n int) + func (m *DeadlockResponse) String() string + func (m *DeadlockResponse) Unmarshal(dAtA []byte) error + func (m *DeadlockResponse) XXX_DiscardUnknown() + func (m *DeadlockResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeadlockResponse) XXX_Merge(src proto.Message) + func (m *DeadlockResponse) XXX_Size() int + func (m *DeadlockResponse) XXX_Unmarshal(b []byte) error + type DeadlockServer interface + Detect func(Deadlock_DetectServer) error + GetWaitForEntries func(context.Context, *WaitForEntriesRequest) (*WaitForEntriesResponse, error) + type Deadlock_DetectClient interface + Recv func() (*DeadlockResponse, error) + Send func(*DeadlockRequest) error + type Deadlock_DetectServer interface + Recv func() (*DeadlockRequest, error) + Send func(*DeadlockResponse) error + type UnimplementedDeadlockServer struct + func (*UnimplementedDeadlockServer) Detect(srv Deadlock_DetectServer) error + func (*UnimplementedDeadlockServer) GetWaitForEntries(ctx context.Context, req *WaitForEntriesRequest) (*WaitForEntriesResponse, error) + type WaitForEntriesRequest struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WaitForEntriesRequest) Descriptor() ([]byte, []int) + func (*WaitForEntriesRequest) ProtoMessage() + func (m *WaitForEntriesRequest) Marshal() (dAtA []byte, err error) + func (m *WaitForEntriesRequest) MarshalTo(dAtA []byte) (int, error) + func (m *WaitForEntriesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *WaitForEntriesRequest) Reset() + func (m *WaitForEntriesRequest) Size() (n int) + func (m *WaitForEntriesRequest) String() string + func (m *WaitForEntriesRequest) Unmarshal(dAtA []byte) error + func (m *WaitForEntriesRequest) XXX_DiscardUnknown() + func (m *WaitForEntriesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WaitForEntriesRequest) XXX_Merge(src proto.Message) + func (m *WaitForEntriesRequest) XXX_Size() int + func (m *WaitForEntriesRequest) XXX_Unmarshal(b []byte) error + type WaitForEntriesResponse struct + Entries []WaitForEntry + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WaitForEntriesResponse) Descriptor() ([]byte, []int) + func (*WaitForEntriesResponse) ProtoMessage() + func (m *WaitForEntriesResponse) GetEntries() []WaitForEntry + func (m *WaitForEntriesResponse) Marshal() (dAtA []byte, err error) + func (m *WaitForEntriesResponse) MarshalTo(dAtA []byte) (int, error) + func (m *WaitForEntriesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *WaitForEntriesResponse) Reset() + func (m *WaitForEntriesResponse) Size() (n int) + func (m *WaitForEntriesResponse) String() string + func (m *WaitForEntriesResponse) Unmarshal(dAtA []byte) error + func (m *WaitForEntriesResponse) XXX_DiscardUnknown() + func (m *WaitForEntriesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WaitForEntriesResponse) XXX_Merge(src proto.Message) + func (m *WaitForEntriesResponse) XXX_Size() int + func (m *WaitForEntriesResponse) XXX_Unmarshal(b []byte) error + type WaitForEntry struct + Key []byte + KeyHash uint64 + ResourceGroupTag []byte + Txn uint64 + WaitForTxn uint64 + WaitTime uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WaitForEntry) Descriptor() ([]byte, []int) + func (*WaitForEntry) ProtoMessage() + func (m *WaitForEntry) GetKey() []byte + func (m *WaitForEntry) GetKeyHash() uint64 + func (m *WaitForEntry) GetResourceGroupTag() []byte + func (m *WaitForEntry) GetTxn() uint64 + func (m *WaitForEntry) GetWaitForTxn() uint64 + func (m *WaitForEntry) GetWaitTime() uint64 + func (m *WaitForEntry) Marshal() (dAtA []byte, err error) + func (m *WaitForEntry) MarshalTo(dAtA []byte) (int, error) + func (m *WaitForEntry) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *WaitForEntry) Reset() + func (m *WaitForEntry) Size() (n int) + func (m *WaitForEntry) String() string + func (m *WaitForEntry) Unmarshal(dAtA []byte) error + func (m *WaitForEntry) XXX_DiscardUnknown() + func (m *WaitForEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WaitForEntry) XXX_Merge(src proto.Message) + func (m *WaitForEntry) XXX_Size() int + func (m *WaitForEntry) XXX_Unmarshal(b []byte) error