corepb

package
v0.0.0-...-73cfedd Latest Latest
Warning

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

 Go to latest Published: Apr 15, 2026 License: AGPL-3.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	PaginationToken_Type_name = map[int32]string{
		0: "NEXT",
		1: "PREVIOUS",
	}
	PaginationToken_Type_value = map[string]int32{
		"NEXT":     0,
		"PREVIOUS": 1,
	}
)

Enum value maps for PaginationToken_Type.

View Source 
var (
	LockState_name = map[int32]string{
		0: "UNLOCKED",
		1: "SHARED_LOCKED",
		2: "EXCLUSIVE_LOCKED",
	}
	LockState_value = map[string]int32{
		"UNLOCKED":         0,
		"SHARED_LOCKED":    1,
		"EXCLUSIVE_LOCKED": 2,
	}
)

Enum value maps for LockState.

View Source 
var File_pkg_corepb_barriers_proto protoreflect.FileDescriptor
View Source 
var File_pkg_corepb_common_proto protoreflect.FileDescriptor
View Source 
var File_pkg_corepb_locks_proto protoreflect.FileDescriptor
View Source 
var File_pkg_corepb_monstera_proto protoreflect.FileDescriptor
View Source 
var File_pkg_corepb_namespaces_proto protoreflect.FileDescriptor
View Source 
var File_pkg_corepb_semaphores_proto protoreflect.FileDescriptor
View Source 
var File_pkg_corepb_wait_groups_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type AcquireLockRequest 

type AcquireLockRequest struct {
	LockId                       *LockId `protobuf:"bytes,1,opt,name=lock_id,json=lockId,proto3" json:"lock_id,omitempty"`
	ProcessId                    string  `protobuf:"bytes,2,opt,name=process_id,json=processId,proto3" json:"process_id,omitempty"`
	Exclusive                    bool    `protobuf:"varint,3,opt,name=exclusive,proto3" json:"exclusive,omitempty"`
	Now                          int64   `protobuf:"varint,4,opt,name=now,proto3" json:"now,omitempty"`
	ExpiresAt                    int64   `protobuf:"varint,5,opt,name=expires_at,json=expiresAt,proto3" json:"expires_at,omitempty"`
	MaxNumberOfLocksPerNamespace int64   `` /* 154-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*AcquireLockRequest) Descriptor deprecated 

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

Deprecated: Use AcquireLockRequest.ProtoReflect.Descriptor instead.

func (*AcquireLockRequest) GetExclusive 

func (x *AcquireLockRequest) GetExclusive() bool

func (*AcquireLockRequest) GetExpiresAt 

func (x *AcquireLockRequest) GetExpiresAt() int64

func (*AcquireLockRequest) GetLockId 

func (x *AcquireLockRequest) GetLockId() *LockId

func (*AcquireLockRequest) GetMaxNumberOfLocksPerNamespace 

func (x *AcquireLockRequest) GetMaxNumberOfLocksPerNamespace() int64

func (*AcquireLockRequest) GetNow 

func (x *AcquireLockRequest) GetNow() int64

func (*AcquireLockRequest) GetProcessId 

func (x *AcquireLockRequest) GetProcessId() string

func (*AcquireLockRequest) ProtoMessage 

func (*AcquireLockRequest) ProtoMessage()

func (*AcquireLockRequest) ProtoReflect 

func (x *AcquireLockRequest) ProtoReflect() protoreflect.Message

func (*AcquireLockRequest) Reset 

func (x *AcquireLockRequest) Reset()

func (*AcquireLockRequest) String 

func (x *AcquireLockRequest) String() string

type AcquireLockResponse 

type AcquireLockResponse struct {
	Lock    *Lock `protobuf:"bytes,1,opt,name=lock,proto3" json:"lock,omitempty"`
	Success bool  `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*AcquireLockResponse) Descriptor deprecated 

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

Deprecated: Use AcquireLockResponse.ProtoReflect.Descriptor instead.

func (*AcquireLockResponse) GetLock 

func (x *AcquireLockResponse) GetLock() *Lock

func (*AcquireLockResponse) GetSuccess 

func (x *AcquireLockResponse) GetSuccess() bool

func (*AcquireLockResponse) ProtoMessage 

func (*AcquireLockResponse) ProtoMessage()

func (*AcquireLockResponse) ProtoReflect 

func (x *AcquireLockResponse) ProtoReflect() protoreflect.Message

func (*AcquireLockResponse) Reset 

func (x *AcquireLockResponse) Reset()

func (*AcquireLockResponse) String 

func (x *AcquireLockResponse) String() string

type AcquireSemaphoreRequest 

type AcquireSemaphoreRequest struct {
	NamespaceId   *NamespaceId `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	SemaphoreName string       `protobuf:"bytes,2,opt,name=semaphore_name,json=semaphoreName,proto3" json:"semaphore_name,omitempty"`
	ProcessId     string       `protobuf:"bytes,3,opt,name=process_id,json=processId,proto3" json:"process_id,omitempty"`
	Weight        uint64       `protobuf:"varint,4,opt,name=weight,proto3" json:"weight,omitempty"`
	ExpiresAt     int64        `protobuf:"varint,5,opt,name=expires_at,json=expiresAt,proto3" json:"expires_at,omitempty"`
	Now           int64        `protobuf:"varint,6,opt,name=now,proto3" json:"now,omitempty"`
	// contains filtered or unexported fields
}

func (*AcquireSemaphoreRequest) Descriptor deprecated 

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

Deprecated: Use AcquireSemaphoreRequest.ProtoReflect.Descriptor instead.

func (*AcquireSemaphoreRequest) GetExpiresAt 

func (x *AcquireSemaphoreRequest) GetExpiresAt() int64

func (*AcquireSemaphoreRequest) GetNamespaceId 

func (x *AcquireSemaphoreRequest) GetNamespaceId() *NamespaceId

func (*AcquireSemaphoreRequest) GetNow 

func (x *AcquireSemaphoreRequest) GetNow() int64

func (*AcquireSemaphoreRequest) GetProcessId 

func (x *AcquireSemaphoreRequest) GetProcessId() string

func (*AcquireSemaphoreRequest) GetSemaphoreName 

func (x *AcquireSemaphoreRequest) GetSemaphoreName() string

func (*AcquireSemaphoreRequest) GetWeight 

func (x *AcquireSemaphoreRequest) GetWeight() uint64

func (*AcquireSemaphoreRequest) ProtoMessage 

func (*AcquireSemaphoreRequest) ProtoMessage()

func (*AcquireSemaphoreRequest) ProtoReflect 

func (x *AcquireSemaphoreRequest) ProtoReflect() protoreflect.Message

func (*AcquireSemaphoreRequest) Reset 

func (x *AcquireSemaphoreRequest) Reset()

func (*AcquireSemaphoreRequest) String 

func (x *AcquireSemaphoreRequest) String() string

type AcquireSemaphoreResponse 

type AcquireSemaphoreResponse struct {
	Semaphore *Semaphore `protobuf:"bytes,1,opt,name=semaphore,proto3" json:"semaphore,omitempty"`
	Success   bool       `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*AcquireSemaphoreResponse) Descriptor deprecated 

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

Deprecated: Use AcquireSemaphoreResponse.ProtoReflect.Descriptor instead.

func (*AcquireSemaphoreResponse) GetSemaphore 

func (x *AcquireSemaphoreResponse) GetSemaphore() *Semaphore

func (*AcquireSemaphoreResponse) GetSuccess 

func (x *AcquireSemaphoreResponse) GetSuccess() bool

func (*AcquireSemaphoreResponse) ProtoMessage 

func (*AcquireSemaphoreResponse) ProtoMessage()

func (*AcquireSemaphoreResponse) ProtoReflect 

func (x *AcquireSemaphoreResponse) ProtoReflect() protoreflect.Message

func (*AcquireSemaphoreResponse) Reset 

func (x *AcquireSemaphoreResponse) Reset()

func (*AcquireSemaphoreResponse) String 

func (x *AcquireSemaphoreResponse) String() string

type AddJobsToWaitGroupRequest 

type AddJobsToWaitGroupRequest struct {
	NamespaceId      *NamespaceId `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	WaitGroupName    string       `protobuf:"bytes,2,opt,name=wait_group_name,json=waitGroupName,proto3" json:"wait_group_name,omitempty"`
	Counter          uint64       `protobuf:"varint,3,opt,name=counter,proto3" json:"counter,omitempty"`
	Now              int64        `protobuf:"varint,4,opt,name=now,proto3" json:"now,omitempty"`
	MaxWaitGroupSize int64        `protobuf:"varint,5,opt,name=max_wait_group_size,json=maxWaitGroupSize,proto3" json:"max_wait_group_size,omitempty"`
	// contains filtered or unexported fields
}

func (*AddJobsToWaitGroupRequest) Descriptor deprecated 

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

Deprecated: Use AddJobsToWaitGroupRequest.ProtoReflect.Descriptor instead.

func (*AddJobsToWaitGroupRequest) GetCounter 

func (x *AddJobsToWaitGroupRequest) GetCounter() uint64

func (*AddJobsToWaitGroupRequest) GetMaxWaitGroupSize 

func (x *AddJobsToWaitGroupRequest) GetMaxWaitGroupSize() int64

func (*AddJobsToWaitGroupRequest) GetNamespaceId 

func (x *AddJobsToWaitGroupRequest) GetNamespaceId() *NamespaceId

func (*AddJobsToWaitGroupRequest) GetNow 

func (x *AddJobsToWaitGroupRequest) GetNow() int64

func (*AddJobsToWaitGroupRequest) GetWaitGroupName 

func (x *AddJobsToWaitGroupRequest) GetWaitGroupName() string

func (*AddJobsToWaitGroupRequest) ProtoMessage 

func (*AddJobsToWaitGroupRequest) ProtoMessage()

func (*AddJobsToWaitGroupRequest) ProtoReflect 

func (x *AddJobsToWaitGroupRequest) ProtoReflect() protoreflect.Message

func (*AddJobsToWaitGroupRequest) Reset 

func (x *AddJobsToWaitGroupRequest) Reset()

func (*AddJobsToWaitGroupRequest) String 

func (x *AddJobsToWaitGroupRequest) String() string

type AddJobsToWaitGroupResponse 

type AddJobsToWaitGroupResponse struct {
	WaitGroup *WaitGroup `protobuf:"bytes,1,opt,name=wait_group,json=waitGroup,proto3" json:"wait_group,omitempty"`
	// contains filtered or unexported fields
}

func (*AddJobsToWaitGroupResponse) Descriptor deprecated 

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

Deprecated: Use AddJobsToWaitGroupResponse.ProtoReflect.Descriptor instead.

func (*AddJobsToWaitGroupResponse) GetWaitGroup 

func (x *AddJobsToWaitGroupResponse) GetWaitGroup() *WaitGroup

func (*AddJobsToWaitGroupResponse) ProtoMessage 

func (*AddJobsToWaitGroupResponse) ProtoMessage()

func (*AddJobsToWaitGroupResponse) ProtoReflect 

func (x *AddJobsToWaitGroupResponse) ProtoReflect() protoreflect.Message

func (*AddJobsToWaitGroupResponse) Reset 

func (x *AddJobsToWaitGroupResponse) Reset()

func (*AddJobsToWaitGroupResponse) String 

func (x *AddJobsToWaitGroupResponse) String() string

type ArriveAtBarrierRequest 

type ArriveAtBarrierRequest struct {
	NamespaceId *NamespaceId `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	BarrierName string       `protobuf:"bytes,2,opt,name=barrier_name,json=barrierName,proto3" json:"barrier_name,omitempty"`
	ProcessId   string       `protobuf:"bytes,3,opt,name=process_id,json=processId,proto3" json:"process_id,omitempty"`
	Generation  uint64       `protobuf:"varint,4,opt,name=generation,proto3" json:"generation,omitempty"`
	Now         int64        `protobuf:"varint,5,opt,name=now,proto3" json:"now,omitempty"`
	// contains filtered or unexported fields
}

func (*ArriveAtBarrierRequest) Descriptor deprecated 

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

Deprecated: Use ArriveAtBarrierRequest.ProtoReflect.Descriptor instead.

func (*ArriveAtBarrierRequest) GetBarrierName 

func (x *ArriveAtBarrierRequest) GetBarrierName() string

func (*ArriveAtBarrierRequest) GetGeneration 

func (x *ArriveAtBarrierRequest) GetGeneration() uint64

func (*ArriveAtBarrierRequest) GetNamespaceId 

func (x *ArriveAtBarrierRequest) GetNamespaceId() *NamespaceId

func (*ArriveAtBarrierRequest) GetNow 

func (x *ArriveAtBarrierRequest) GetNow() int64

func (*ArriveAtBarrierRequest) GetProcessId 

func (x *ArriveAtBarrierRequest) GetProcessId() string

func (*ArriveAtBarrierRequest) ProtoMessage 

func (*ArriveAtBarrierRequest) ProtoMessage()

func (*ArriveAtBarrierRequest) ProtoReflect 

func (x *ArriveAtBarrierRequest) ProtoReflect() protoreflect.Message

func (*ArriveAtBarrierRequest) Reset 

func (x *ArriveAtBarrierRequest) Reset()

func (*ArriveAtBarrierRequest) String 

func (x *ArriveAtBarrierRequest) String() string

type ArriveAtBarrierResponse 

type ArriveAtBarrierResponse struct {
	Barrier *Barrier `protobuf:"bytes,1,opt,name=barrier,proto3" json:"barrier,omitempty"`
	// contains filtered or unexported fields
}

func (*ArriveAtBarrierResponse) Descriptor deprecated 

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

Deprecated: Use ArriveAtBarrierResponse.ProtoReflect.Descriptor instead.

func (*ArriveAtBarrierResponse) GetBarrier 

func (x *ArriveAtBarrierResponse) GetBarrier() *Barrier

func (*ArriveAtBarrierResponse) ProtoMessage 

func (*ArriveAtBarrierResponse) ProtoMessage()

func (*ArriveAtBarrierResponse) ProtoReflect 

func (x *ArriveAtBarrierResponse) ProtoReflect() protoreflect.Message

func (*ArriveAtBarrierResponse) Reset 

func (x *ArriveAtBarrierResponse) Reset()

func (*ArriveAtBarrierResponse) String 

func (x *ArriveAtBarrierResponse) String() string

type Barrier 

type Barrier struct {
	Id                *BarrierId `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name              string     `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Description       string     `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	CreatedAt         int64      `protobuf:"varint,4,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt         int64      `protobuf:"varint,5,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	ExpectedProcesses uint64     `protobuf:"varint,6,opt,name=expected_processes,json=expectedProcesses,proto3" json:"expected_processes,omitempty"`
	ArrivedProcesses  uint64     `protobuf:"varint,7,opt,name=arrived_processes,json=arrivedProcesses,proto3" json:"arrived_processes,omitempty"`
	Generation        uint64     `protobuf:"varint,8,opt,name=generation,proto3" json:"generation,omitempty"`
	// contains filtered or unexported fields
}

func (*Barrier) Descriptor deprecated 

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

Deprecated: Use Barrier.ProtoReflect.Descriptor instead.

func (*Barrier) GetArrivedProcesses 

func (x *Barrier) GetArrivedProcesses() uint64

func (*Barrier) GetCreatedAt 

func (x *Barrier) GetCreatedAt() int64

func (*Barrier) GetDescription 

func (x *Barrier) GetDescription() string

func (*Barrier) GetExpectedProcesses 

func (x *Barrier) GetExpectedProcesses() uint64

func (*Barrier) GetGeneration 

func (x *Barrier) GetGeneration() uint64

func (*Barrier) GetId 

func (x *Barrier) GetId() *BarrierId

func (*Barrier) GetName 

func (x *Barrier) GetName() string

func (*Barrier) GetUpdatedAt 

func (x *Barrier) GetUpdatedAt() int64

func (*Barrier) MarshalBinary 

func (m *Barrier) MarshalBinary() (data []byte, err error)

func (*Barrier) ProtoMessage 

func (*Barrier) ProtoMessage()

func (*Barrier) ProtoReflect 

func (x *Barrier) ProtoReflect() protoreflect.Message

func (*Barrier) Reset 

func (x *Barrier) Reset()

func (*Barrier) String 

func (x *Barrier) String() string

func (*Barrier) UnmarshalBinary 

func (m *Barrier) UnmarshalBinary(data []byte) error

type BarrierId 

type BarrierId struct {
	AccountId   uint64 `protobuf:"varint,1,opt,name=account_id,json=accountId,proto3" json:"account_id,omitempty"`
	NamespaceId uint32 `protobuf:"varint,2,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	BarrierId   uint64 `protobuf:"varint,4,opt,name=barrier_id,json=barrierId,proto3" json:"barrier_id,omitempty"`
	// contains filtered or unexported fields
}

func (*BarrierId) Descriptor deprecated 

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

Deprecated: Use BarrierId.ProtoReflect.Descriptor instead.

func (*BarrierId) GetAccountId 

func (x *BarrierId) GetAccountId() uint64

func (*BarrierId) GetBarrierId 

func (x *BarrierId) GetBarrierId() uint64

func (*BarrierId) GetNamespaceId 

func (x *BarrierId) GetNamespaceId() uint32

func (*BarrierId) ProtoMessage 

func (*BarrierId) ProtoMessage()

func (*BarrierId) ProtoReflect 

func (x *BarrierId) ProtoReflect() protoreflect.Message

func (*BarrierId) Reset 

func (x *BarrierId) Reset()

func (*BarrierId) String 

func (x *BarrierId) String() string

type BarrierParticipant 

type BarrierParticipant struct {
	ProcessId  string `protobuf:"bytes,1,opt,name=process_id,json=processId,proto3" json:"process_id,omitempty"`
	ArrivedAt  int64  `protobuf:"varint,2,opt,name=arrived_at,json=arrivedAt,proto3" json:"arrived_at,omitempty"`
	Generation uint64 `protobuf:"varint,3,opt,name=generation,proto3" json:"generation,omitempty"`
	// contains filtered or unexported fields
}

func (*BarrierParticipant) Descriptor deprecated 

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

Deprecated: Use BarrierParticipant.ProtoReflect.Descriptor instead.

func (*BarrierParticipant) GetArrivedAt 

func (x *BarrierParticipant) GetArrivedAt() int64

func (*BarrierParticipant) GetGeneration 

func (x *BarrierParticipant) GetGeneration() uint64

func (*BarrierParticipant) GetProcessId 

func (x *BarrierParticipant) GetProcessId() string

func (*BarrierParticipant) MarshalBinary 

func (m *BarrierParticipant) MarshalBinary() (data []byte, err error)

func (*BarrierParticipant) ProtoMessage 

func (*BarrierParticipant) ProtoMessage()

func (*BarrierParticipant) ProtoReflect 

func (x *BarrierParticipant) ProtoReflect() protoreflect.Message

func (*BarrierParticipant) Reset 

func (x *BarrierParticipant) Reset()

func (*BarrierParticipant) String 

func (x *BarrierParticipant) String() string

func (*BarrierParticipant) UnmarshalBinary 

func (m *BarrierParticipant) UnmarshalBinary(data []byte) error

type BarriersCounter 

type BarriersCounter struct {
	NamespaceId      *NamespaceId `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	NumberOfBarriers int64        `protobuf:"varint,2,opt,name=number_of_barriers,json=numberOfBarriers,proto3" json:"number_of_barriers,omitempty"`
	// contains filtered or unexported fields
}

func (*BarriersCounter) Descriptor deprecated 

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

Deprecated: Use BarriersCounter.ProtoReflect.Descriptor instead.

func (*BarriersCounter) GetNamespaceId 

func (x *BarriersCounter) GetNamespaceId() *NamespaceId

func (*BarriersCounter) GetNumberOfBarriers 

func (x *BarriersCounter) GetNumberOfBarriers() int64

func (*BarriersCounter) MarshalBinary 

func (m *BarriersCounter) MarshalBinary() (data []byte, err error)

func (*BarriersCounter) ProtoMessage 

func (*BarriersCounter) ProtoMessage()

func (*BarriersCounter) ProtoReflect 

func (x *BarriersCounter) ProtoReflect() protoreflect.Message

func (*BarriersCounter) Reset 

func (x *BarriersCounter) Reset()

func (*BarriersCounter) String 

func (x *BarriersCounter) String() string

func (*BarriersCounter) UnmarshalBinary 

func (m *BarriersCounter) UnmarshalBinary(data []byte) error

type BarriersDeleteNamespaceRequest 

type BarriersDeleteNamespaceRequest struct {
	NamespaceId *NamespaceId `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	RecordId    uint64       `protobuf:"varint,2,opt,name=record_id,json=recordId,proto3" json:"record_id,omitempty"`
	Now         int64        `protobuf:"varint,3,opt,name=now,proto3" json:"now,omitempty"`
	// contains filtered or unexported fields
}

func (*BarriersDeleteNamespaceRequest) Descriptor deprecated 

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

Deprecated: Use BarriersDeleteNamespaceRequest.ProtoReflect.Descriptor instead.

func (*BarriersDeleteNamespaceRequest) GetNamespaceId 

func (x *BarriersDeleteNamespaceRequest) GetNamespaceId() *NamespaceId

func (*BarriersDeleteNamespaceRequest) GetNow 

func (x *BarriersDeleteNamespaceRequest) GetNow() int64

func (*BarriersDeleteNamespaceRequest) GetRecordId 

func (x *BarriersDeleteNamespaceRequest) GetRecordId() uint64

func (*BarriersDeleteNamespaceRequest) ProtoMessage 

func (*BarriersDeleteNamespaceRequest) ProtoMessage()

func (*BarriersDeleteNamespaceRequest) ProtoReflect 

func (x *BarriersDeleteNamespaceRequest) ProtoReflect() protoreflect.Message

func (*BarriersDeleteNamespaceRequest) Reset 

func (x *BarriersDeleteNamespaceRequest) Reset()

func (*BarriersDeleteNamespaceRequest) String 

func (x *BarriersDeleteNamespaceRequest) String() string

type BarriersDeleteNamespaceResponse 

type BarriersDeleteNamespaceResponse struct {
	// contains filtered or unexported fields
}

func (*BarriersDeleteNamespaceResponse) Descriptor deprecated 

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

Deprecated: Use BarriersDeleteNamespaceResponse.ProtoReflect.Descriptor instead.

func (*BarriersDeleteNamespaceResponse) ProtoMessage 

func (*BarriersDeleteNamespaceResponse) ProtoMessage()

func (*BarriersDeleteNamespaceResponse) ProtoReflect 

func (x *BarriersDeleteNamespaceResponse) ProtoReflect() protoreflect.Message

func (*BarriersDeleteNamespaceResponse) Reset 

func (x *BarriersDeleteNamespaceResponse) Reset()

func (*BarriersDeleteNamespaceResponse) String 

func (x *BarriersDeleteNamespaceResponse) String() string

type BarriersExpirationRecord 

type BarriersExpirationRecord struct {
	BarrierId *BarrierId `protobuf:"bytes,1,opt,name=barrier_id,json=barrierId,proto3" json:"barrier_id,omitempty"`
	ExpiresAt int64      `protobuf:"varint,2,opt,name=expires_at,json=expiresAt,proto3" json:"expires_at,omitempty"`
	// contains filtered or unexported fields
}

func (*BarriersExpirationRecord) Descriptor deprecated 

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

Deprecated: Use BarriersExpirationRecord.ProtoReflect.Descriptor instead.

func (*BarriersExpirationRecord) GetBarrierId 

func (x *BarriersExpirationRecord) GetBarrierId() *BarrierId

func (*BarriersExpirationRecord) GetExpiresAt 

func (x *BarriersExpirationRecord) GetExpiresAt() int64

func (*BarriersExpirationRecord) MarshalBinary 

func (m *BarriersExpirationRecord) MarshalBinary() (data []byte, err error)

func (*BarriersExpirationRecord) ProtoMessage 

func (*BarriersExpirationRecord) ProtoMessage()

func (*BarriersExpirationRecord) ProtoReflect 

func (x *BarriersExpirationRecord) ProtoReflect() protoreflect.Message

func (*BarriersExpirationRecord) Reset 

func (x *BarriersExpirationRecord) Reset()

func (*BarriersExpirationRecord) String 

func (x *BarriersExpirationRecord) String() string

func (*BarriersExpirationRecord) UnmarshalBinary 

func (m *BarriersExpirationRecord) UnmarshalBinary(data []byte) error

type BarriersGarbageCollectionRecord 

type BarriersGarbageCollectionRecord struct {
	Id          uint64       `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	NamespaceId *NamespaceId `protobuf:"bytes,2,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	// contains filtered or unexported fields
}

func (*BarriersGarbageCollectionRecord) Descriptor deprecated 

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

Deprecated: Use BarriersGarbageCollectionRecord.ProtoReflect.Descriptor instead.

func (*BarriersGarbageCollectionRecord) GetId 

func (x *BarriersGarbageCollectionRecord) GetId() uint64

func (*BarriersGarbageCollectionRecord) GetNamespaceId 

func (x *BarriersGarbageCollectionRecord) GetNamespaceId() *NamespaceId

func (*BarriersGarbageCollectionRecord) MarshalBinary 

func (m *BarriersGarbageCollectionRecord) MarshalBinary() (data []byte, err error)

func (*BarriersGarbageCollectionRecord) ProtoMessage 

func (*BarriersGarbageCollectionRecord) ProtoMessage()

func (*BarriersGarbageCollectionRecord) ProtoReflect 

func (x *BarriersGarbageCollectionRecord) ProtoReflect() protoreflect.Message

func (*BarriersGarbageCollectionRecord) Reset 

func (x *BarriersGarbageCollectionRecord) Reset()

func (*BarriersGarbageCollectionRecord) String 

func (x *BarriersGarbageCollectionRecord) String() string

func (*BarriersGarbageCollectionRecord) UnmarshalBinary 

func (m *BarriersGarbageCollectionRecord) UnmarshalBinary(data []byte) error

type CompleteJobsFromWaitGroupRequest 

type CompleteJobsFromWaitGroupRequest struct {
	NamespaceId   *NamespaceId `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	WaitGroupName string       `protobuf:"bytes,2,opt,name=wait_group_name,json=waitGroupName,proto3" json:"wait_group_name,omitempty"`
	ProcessIds    []string     `protobuf:"bytes,3,rep,name=process_ids,json=processIds,proto3" json:"process_ids,omitempty"`
	Now           int64        `protobuf:"varint,4,opt,name=now,proto3" json:"now,omitempty"`
	// contains filtered or unexported fields
}

func (*CompleteJobsFromWaitGroupRequest) Descriptor deprecated 

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

Deprecated: Use CompleteJobsFromWaitGroupRequest.ProtoReflect.Descriptor instead.

func (*CompleteJobsFromWaitGroupRequest) GetNamespaceId 

func (x *CompleteJobsFromWaitGroupRequest) GetNamespaceId() *NamespaceId

func (*CompleteJobsFromWaitGroupRequest) GetNow 

func (x *CompleteJobsFromWaitGroupRequest) GetNow() int64

func (*CompleteJobsFromWaitGroupRequest) GetProcessIds 

func (x *CompleteJobsFromWaitGroupRequest) GetProcessIds() []string

func (*CompleteJobsFromWaitGroupRequest) GetWaitGroupName 

func (x *CompleteJobsFromWaitGroupRequest) GetWaitGroupName() string

func (*CompleteJobsFromWaitGroupRequest) ProtoMessage 

func (*CompleteJobsFromWaitGroupRequest) ProtoMessage()

func (*CompleteJobsFromWaitGroupRequest) ProtoReflect 

func (x *CompleteJobsFromWaitGroupRequest) ProtoReflect() protoreflect.Message

func (*CompleteJobsFromWaitGroupRequest) Reset 

func (x *CompleteJobsFromWaitGroupRequest) Reset()

func (*CompleteJobsFromWaitGroupRequest) String 

func (x *CompleteJobsFromWaitGroupRequest) String() string

type CompleteJobsFromWaitGroupResponse 

type CompleteJobsFromWaitGroupResponse struct {
	WaitGroup *WaitGroup `protobuf:"bytes,1,opt,name=wait_group,json=waitGroup,proto3" json:"wait_group,omitempty"`
	// contains filtered or unexported fields
}

func (*CompleteJobsFromWaitGroupResponse) Descriptor deprecated 

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

Deprecated: Use CompleteJobsFromWaitGroupResponse.ProtoReflect.Descriptor instead.

func (*CompleteJobsFromWaitGroupResponse) GetWaitGroup 

func (x *CompleteJobsFromWaitGroupResponse) GetWaitGroup() *WaitGroup

func (*CompleteJobsFromWaitGroupResponse) ProtoMessage 

func (*CompleteJobsFromWaitGroupResponse) ProtoMessage()

func (*CompleteJobsFromWaitGroupResponse) ProtoReflect 

func (x *CompleteJobsFromWaitGroupResponse) ProtoReflect() protoreflect.Message

func (*CompleteJobsFromWaitGroupResponse) Reset 

func (x *CompleteJobsFromWaitGroupResponse) Reset()

func (*CompleteJobsFromWaitGroupResponse) String 

func (x *CompleteJobsFromWaitGroupResponse) String() string

type CreateBarrierRequest 

type CreateBarrierRequest struct {
	BarrierId                       *BarrierId `protobuf:"bytes,1,opt,name=barrier_id,json=barrierId,proto3" json:"barrier_id,omitempty"`
	Name                            string     `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Description                     string     `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	ExpectedProcesses               uint64     `protobuf:"varint,4,opt,name=expected_processes,json=expectedProcesses,proto3" json:"expected_processes,omitempty"`
	Now                             int64      `protobuf:"varint,5,opt,name=now,proto3" json:"now,omitempty"`
	MaxNumberOfBarriersPerNamespace int64      `` /* 163-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CreateBarrierRequest) Descriptor deprecated 

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

Deprecated: Use CreateBarrierRequest.ProtoReflect.Descriptor instead.

func (*CreateBarrierRequest) GetBarrierId 

func (x *CreateBarrierRequest) GetBarrierId() *BarrierId

func (*CreateBarrierRequest) GetDescription 

func (x *CreateBarrierRequest) GetDescription() string

func (*CreateBarrierRequest) GetExpectedProcesses 

func (x *CreateBarrierRequest) GetExpectedProcesses() uint64

func (*CreateBarrierRequest) GetMaxNumberOfBarriersPerNamespace 

func (x *CreateBarrierRequest) GetMaxNumberOfBarriersPerNamespace() int64

func (*CreateBarrierRequest) GetName 

func (x *CreateBarrierRequest) GetName() string

func (*CreateBarrierRequest) GetNow 

func (x *CreateBarrierRequest) GetNow() int64

func (*CreateBarrierRequest) ProtoMessage 

func (*CreateBarrierRequest) ProtoMessage()

func (*CreateBarrierRequest) ProtoReflect 

func (x *CreateBarrierRequest) ProtoReflect() protoreflect.Message

func (*CreateBarrierRequest) Reset 

func (x *CreateBarrierRequest) Reset()

func (*CreateBarrierRequest) String 

func (x *CreateBarrierRequest) String() string

type CreateBarrierResponse 

type CreateBarrierResponse struct {
	Barrier *Barrier `protobuf:"bytes,1,opt,name=barrier,proto3" json:"barrier,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateBarrierResponse) Descriptor deprecated 

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

Deprecated: Use CreateBarrierResponse.ProtoReflect.Descriptor instead.

func (*CreateBarrierResponse) GetBarrier 

func (x *CreateBarrierResponse) GetBarrier() *Barrier

func (*CreateBarrierResponse) ProtoMessage 

func (*CreateBarrierResponse) ProtoMessage()

func (*CreateBarrierResponse) ProtoReflect 

func (x *CreateBarrierResponse) ProtoReflect() protoreflect.Message

func (*CreateBarrierResponse) Reset 

func (x *CreateBarrierResponse) Reset()

func (*CreateBarrierResponse) String 

func (x *CreateBarrierResponse) String() string

type CreateNamespaceRequest 

type CreateNamespaceRequest struct {
	NamespaceId           *NamespaceId `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	Name                  string       `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Description           string       `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	Now                   int64        `protobuf:"varint,4,opt,name=now,proto3" json:"now,omitempty"`
	MaxNumberOfNamespaces int64        `` /* 129-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CreateNamespaceRequest) Descriptor deprecated 

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

Deprecated: Use CreateNamespaceRequest.ProtoReflect.Descriptor instead.

func (*CreateNamespaceRequest) GetDescription 

func (x *CreateNamespaceRequest) GetDescription() string

func (*CreateNamespaceRequest) GetMaxNumberOfNamespaces 

func (x *CreateNamespaceRequest) GetMaxNumberOfNamespaces() int64

func (*CreateNamespaceRequest) GetName 

func (x *CreateNamespaceRequest) GetName() string

func (*CreateNamespaceRequest) GetNamespaceId 

func (x *CreateNamespaceRequest) GetNamespaceId() *NamespaceId

func (*CreateNamespaceRequest) GetNow 

func (x *CreateNamespaceRequest) GetNow() int64

func (*CreateNamespaceRequest) ProtoMessage 

func (*CreateNamespaceRequest) ProtoMessage()

func (*CreateNamespaceRequest) ProtoReflect 

func (x *CreateNamespaceRequest) ProtoReflect() protoreflect.Message

func (*CreateNamespaceRequest) Reset 

func (x *CreateNamespaceRequest) Reset()

func (*CreateNamespaceRequest) String 

func (x *CreateNamespaceRequest) String() string

type CreateNamespaceResponse 

type CreateNamespaceResponse struct {
	Namespace *Namespace `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateNamespaceResponse) Descriptor deprecated 

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

Deprecated: Use CreateNamespaceResponse.ProtoReflect.Descriptor instead.

func (*CreateNamespaceResponse) GetNamespace 

func (x *CreateNamespaceResponse) GetNamespace() *Namespace

func (*CreateNamespaceResponse) ProtoMessage 

func (*CreateNamespaceResponse) ProtoMessage()

func (*CreateNamespaceResponse) ProtoReflect 

func (x *CreateNamespaceResponse) ProtoReflect() protoreflect.Message

func (*CreateNamespaceResponse) Reset 

func (x *CreateNamespaceResponse) Reset()

func (*CreateNamespaceResponse) String 

func (x *CreateNamespaceResponse) String() string

type CreateSemaphoreRequest 

type CreateSemaphoreRequest struct {
	SemaphoreId                       *SemaphoreId `protobuf:"bytes,1,opt,name=semaphore_id,json=semaphoreId,proto3" json:"semaphore_id,omitempty"`
	Name                              string       `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Description                       string       `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	Now                               int64        `protobuf:"varint,4,opt,name=now,proto3" json:"now,omitempty"`
	Permits                           uint64       `protobuf:"varint,5,opt,name=permits,proto3" json:"permits,omitempty"`
	MaxNumberOfSemaphoresPerNamespace int64        `` /* 169-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CreateSemaphoreRequest) Descriptor deprecated 

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

Deprecated: Use CreateSemaphoreRequest.ProtoReflect.Descriptor instead.

func (*CreateSemaphoreRequest) GetDescription 

func (x *CreateSemaphoreRequest) GetDescription() string

func (*CreateSemaphoreRequest) GetMaxNumberOfSemaphoresPerNamespace 

func (x *CreateSemaphoreRequest) GetMaxNumberOfSemaphoresPerNamespace() int64

func (*CreateSemaphoreRequest) GetName 

func (x *CreateSemaphoreRequest) GetName() string

func (*CreateSemaphoreRequest) GetNow 

func (x *CreateSemaphoreRequest) GetNow() int64

func (*CreateSemaphoreRequest) GetPermits 

func (x *CreateSemaphoreRequest) GetPermits() uint64

func (*CreateSemaphoreRequest) GetSemaphoreId 

func (x *CreateSemaphoreRequest) GetSemaphoreId() *SemaphoreId

func (*CreateSemaphoreRequest) ProtoMessage 

func (*CreateSemaphoreRequest) ProtoMessage()

func (*CreateSemaphoreRequest) ProtoReflect 

func (x *CreateSemaphoreRequest) ProtoReflect() protoreflect.Message

func (*CreateSemaphoreRequest) Reset 

func (x *CreateSemaphoreRequest) Reset()

func (*CreateSemaphoreRequest) String 

func (x *CreateSemaphoreRequest) String() string

type CreateSemaphoreResponse 

type CreateSemaphoreResponse struct {
	Semaphore *Semaphore `protobuf:"bytes,1,opt,name=semaphore,proto3" json:"semaphore,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateSemaphoreResponse) Descriptor deprecated 

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

Deprecated: Use CreateSemaphoreResponse.ProtoReflect.Descriptor instead.

func (*CreateSemaphoreResponse) GetSemaphore 

func (x *CreateSemaphoreResponse) GetSemaphore() *Semaphore

func (*CreateSemaphoreResponse) ProtoMessage 

func (*CreateSemaphoreResponse) ProtoMessage()

func (*CreateSemaphoreResponse) ProtoReflect 

func (x *CreateSemaphoreResponse) ProtoReflect() protoreflect.Message

func (*CreateSemaphoreResponse) Reset 

func (x *CreateSemaphoreResponse) Reset()

func (*CreateSemaphoreResponse) String 

func (x *CreateSemaphoreResponse) String() string

type CreateWaitGroupRequest 

type CreateWaitGroupRequest struct {
	WaitGroupId                       *WaitGroupId `protobuf:"bytes,1,opt,name=wait_group_id,json=waitGroupId,proto3" json:"wait_group_id,omitempty"`
	Name                              string       `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Description                       string       `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	Now                               int64        `protobuf:"varint,4,opt,name=now,proto3" json:"now,omitempty"`
	Counter                           uint64       `protobuf:"varint,5,opt,name=counter,proto3" json:"counter,omitempty"`
	ExpiresAt                         int64        `protobuf:"varint,6,opt,name=expires_at,json=expiresAt,proto3" json:"expires_at,omitempty"`
	MaxNumberOfWaitGroupsPerNamespace int64        `` /* 171-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CreateWaitGroupRequest) Descriptor deprecated 

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

Deprecated: Use CreateWaitGroupRequest.ProtoReflect.Descriptor instead.

func (*CreateWaitGroupRequest) GetCounter 

func (x *CreateWaitGroupRequest) GetCounter() uint64

func (*CreateWaitGroupRequest) GetDescription 

func (x *CreateWaitGroupRequest) GetDescription() string

func (*CreateWaitGroupRequest) GetExpiresAt 

func (x *CreateWaitGroupRequest) GetExpiresAt() int64

func (*CreateWaitGroupRequest) GetMaxNumberOfWaitGroupsPerNamespace 

func (x *CreateWaitGroupRequest) GetMaxNumberOfWaitGroupsPerNamespace() int64

func (*CreateWaitGroupRequest) GetName 

func (x *CreateWaitGroupRequest) GetName() string

func (*CreateWaitGroupRequest) GetNow 

func (x *CreateWaitGroupRequest) GetNow() int64

func (*CreateWaitGroupRequest) GetWaitGroupId 

func (x *CreateWaitGroupRequest) GetWaitGroupId() *WaitGroupId

func (*CreateWaitGroupRequest) ProtoMessage 

func (*CreateWaitGroupRequest) ProtoMessage()

func (*CreateWaitGroupRequest) ProtoReflect 

func (x *CreateWaitGroupRequest) ProtoReflect() protoreflect.Message

func (*CreateWaitGroupRequest) Reset 

func (x *CreateWaitGroupRequest) Reset()

func (*CreateWaitGroupRequest) String 

func (x *CreateWaitGroupRequest) String() string

type CreateWaitGroupResponse 

type CreateWaitGroupResponse struct {
	WaitGroup *WaitGroup `protobuf:"bytes,1,opt,name=wait_group,json=waitGroup,proto3" json:"wait_group,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateWaitGroupResponse) Descriptor deprecated 

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

Deprecated: Use CreateWaitGroupResponse.ProtoReflect.Descriptor instead.

func (*CreateWaitGroupResponse) GetWaitGroup 

func (x *CreateWaitGroupResponse) GetWaitGroup() *WaitGroup

func (*CreateWaitGroupResponse) ProtoMessage 

func (*CreateWaitGroupResponse) ProtoMessage()

func (*CreateWaitGroupResponse) ProtoReflect 

func (x *CreateWaitGroupResponse) ProtoReflect() protoreflect.Message

func (*CreateWaitGroupResponse) Reset 

func (x *CreateWaitGroupResponse) Reset()

func (*CreateWaitGroupResponse) String 

func (x *CreateWaitGroupResponse) String() string

type DeleteBarrierRequest 

type DeleteBarrierRequest struct {
	NamespaceId *NamespaceId `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	BarrierName string       `protobuf:"bytes,2,opt,name=barrier_name,json=barrierName,proto3" json:"barrier_name,omitempty"`
	Now         int64        `protobuf:"varint,3,opt,name=now,proto3" json:"now,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteBarrierRequest) Descriptor deprecated 

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

Deprecated: Use DeleteBarrierRequest.ProtoReflect.Descriptor instead.

func (*DeleteBarrierRequest) GetBarrierName 

func (x *DeleteBarrierRequest) GetBarrierName() string

func (*DeleteBarrierRequest) GetNamespaceId 

func (x *DeleteBarrierRequest) GetNamespaceId() *NamespaceId

func (*DeleteBarrierRequest) GetNow 

func (x *DeleteBarrierRequest) GetNow() int64

func (*DeleteBarrierRequest) ProtoMessage 

func (*DeleteBarrierRequest) ProtoMessage()

func (*DeleteBarrierRequest) ProtoReflect 

func (x *DeleteBarrierRequest) ProtoReflect() protoreflect.Message

func (*DeleteBarrierRequest) Reset 

func (x *DeleteBarrierRequest) Reset()

func (*DeleteBarrierRequest) String 

func (x *DeleteBarrierRequest) String() string

type DeleteBarrierResponse 

type DeleteBarrierResponse struct {
	// contains filtered or unexported fields
}

func (*DeleteBarrierResponse) Descriptor deprecated 

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

Deprecated: Use DeleteBarrierResponse.ProtoReflect.Descriptor instead.

func (*DeleteBarrierResponse) ProtoMessage 

func (*DeleteBarrierResponse) ProtoMessage()

func (*DeleteBarrierResponse) ProtoReflect 

func (x *DeleteBarrierResponse) ProtoReflect() protoreflect.Message

func (*DeleteBarrierResponse) Reset 

func (x *DeleteBarrierResponse) Reset()

func (*DeleteBarrierResponse) String 

func (x *DeleteBarrierResponse) String() string

type DeleteLockRequest 

type DeleteLockRequest struct {
	LockId *LockId `protobuf:"bytes,1,opt,name=lock_id,json=lockId,proto3" json:"lock_id,omitempty"`
	Now    int64   `protobuf:"varint,2,opt,name=now,proto3" json:"now,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteLockRequest) Descriptor deprecated 

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

Deprecated: Use DeleteLockRequest.ProtoReflect.Descriptor instead.

func (*DeleteLockRequest) GetLockId 

func (x *DeleteLockRequest) GetLockId() *LockId

func (*DeleteLockRequest) GetNow 

func (x *DeleteLockRequest) GetNow() int64

func (*DeleteLockRequest) ProtoMessage 

func (*DeleteLockRequest) ProtoMessage()

func (*DeleteLockRequest) ProtoReflect 

func (x *DeleteLockRequest) ProtoReflect() protoreflect.Message

func (*DeleteLockRequest) Reset 

func (x *DeleteLockRequest) Reset()

func (*DeleteLockRequest) String 

func (x *DeleteLockRequest) String() string

type DeleteLockResponse 

type DeleteLockResponse struct {
	// contains filtered or unexported fields
}

func (*DeleteLockResponse) Descriptor deprecated 

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

Deprecated: Use DeleteLockResponse.ProtoReflect.Descriptor instead.

func (*DeleteLockResponse) ProtoMessage 

func (*DeleteLockResponse) ProtoMessage()

func (*DeleteLockResponse) ProtoReflect 

func (x *DeleteLockResponse) ProtoReflect() protoreflect.Message

func (*DeleteLockResponse) Reset 

func (x *DeleteLockResponse) Reset()

func (*DeleteLockResponse) String 

func (x *DeleteLockResponse) String() string

type DeleteNamespaceRequest 

type DeleteNamespaceRequest struct {
	NamespaceId *NamespaceId `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	Now         int64        `protobuf:"varint,2,opt,name=now,proto3" json:"now,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteNamespaceRequest) Descriptor deprecated 

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

Deprecated: Use DeleteNamespaceRequest.ProtoReflect.Descriptor instead.

func (*DeleteNamespaceRequest) GetNamespaceId 

func (x *DeleteNamespaceRequest) GetNamespaceId() *NamespaceId

func (*DeleteNamespaceRequest) GetNow 

func (x *DeleteNamespaceRequest) GetNow() int64

func (*DeleteNamespaceRequest) ProtoMessage 

func (*DeleteNamespaceRequest) ProtoMessage()

func (*DeleteNamespaceRequest) ProtoReflect 

func (x *DeleteNamespaceRequest) ProtoReflect() protoreflect.Message

func (*DeleteNamespaceRequest) Reset 

func (x *DeleteNamespaceRequest) Reset()

func (*DeleteNamespaceRequest) String 

func (x *DeleteNamespaceRequest) String() string

type DeleteNamespaceResponse 

type DeleteNamespaceResponse struct {
	// contains filtered or unexported fields
}

func (*DeleteNamespaceResponse) Descriptor deprecated 

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

Deprecated: Use DeleteNamespaceResponse.ProtoReflect.Descriptor instead.

func (*DeleteNamespaceResponse) ProtoMessage 

func (*DeleteNamespaceResponse) ProtoMessage()

func (*DeleteNamespaceResponse) ProtoReflect 

func (x *DeleteNamespaceResponse) ProtoReflect() protoreflect.Message

func (*DeleteNamespaceResponse) Reset 

func (x *DeleteNamespaceResponse) Reset()

func (*DeleteNamespaceResponse) String 

func (x *DeleteNamespaceResponse) String() string

type DeleteSemaphoreRequest 

type DeleteSemaphoreRequest struct {
	NamespaceId   *NamespaceId `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	SemaphoreName string       `protobuf:"bytes,2,opt,name=semaphore_name,json=semaphoreName,proto3" json:"semaphore_name,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteSemaphoreRequest) Descriptor deprecated 

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

Deprecated: Use DeleteSemaphoreRequest.ProtoReflect.Descriptor instead.

func (*DeleteSemaphoreRequest) GetNamespaceId 

func (x *DeleteSemaphoreRequest) GetNamespaceId() *NamespaceId

func (*DeleteSemaphoreRequest) GetSemaphoreName 

func (x *DeleteSemaphoreRequest) GetSemaphoreName() string

func (*DeleteSemaphoreRequest) ProtoMessage 

func (*DeleteSemaphoreRequest) ProtoMessage()

func (*DeleteSemaphoreRequest) ProtoReflect 

func (x *DeleteSemaphoreRequest) ProtoReflect() protoreflect.Message

func (*DeleteSemaphoreRequest) Reset 

func (x *DeleteSemaphoreRequest) Reset()

func (*DeleteSemaphoreRequest) String 

func (x *DeleteSemaphoreRequest) String() string

type DeleteSemaphoreResponse 

type DeleteSemaphoreResponse struct {
	// contains filtered or unexported fields
}

func (*DeleteSemaphoreResponse) Descriptor deprecated 

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

Deprecated: Use DeleteSemaphoreResponse.ProtoReflect.Descriptor instead.

func (*DeleteSemaphoreResponse) ProtoMessage 

func (*DeleteSemaphoreResponse) ProtoMessage()

func (*DeleteSemaphoreResponse) ProtoReflect 

func (x *DeleteSemaphoreResponse) ProtoReflect() protoreflect.Message

func (*DeleteSemaphoreResponse) Reset 

func (x *DeleteSemaphoreResponse) Reset()

func (*DeleteSemaphoreResponse) String 

func (x *DeleteSemaphoreResponse) String() string

type DeleteWaitGroupRequest 

type DeleteWaitGroupRequest struct {
	NamespaceId   *NamespaceId `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	WaitGroupName string       `protobuf:"bytes,2,opt,name=wait_group_name,json=waitGroupName,proto3" json:"wait_group_name,omitempty"`
	RecordId      uint64       `protobuf:"varint,3,opt,name=record_id,json=recordId,proto3" json:"record_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteWaitGroupRequest) Descriptor deprecated 

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

Deprecated: Use DeleteWaitGroupRequest.ProtoReflect.Descriptor instead.

func (*DeleteWaitGroupRequest) GetNamespaceId 

func (x *DeleteWaitGroupRequest) GetNamespaceId() *NamespaceId

func (*DeleteWaitGroupRequest) GetRecordId 

func (x *DeleteWaitGroupRequest) GetRecordId() uint64

func (*DeleteWaitGroupRequest) GetWaitGroupName 

func (x *DeleteWaitGroupRequest) GetWaitGroupName() string

func (*DeleteWaitGroupRequest) ProtoMessage 

func (*DeleteWaitGroupRequest) ProtoMessage()

func (*DeleteWaitGroupRequest) ProtoReflect 

func (x *DeleteWaitGroupRequest) ProtoReflect() protoreflect.Message

func (*DeleteWaitGroupRequest) Reset 

func (x *DeleteWaitGroupRequest) Reset()

func (*DeleteWaitGroupRequest) String 

func (x *DeleteWaitGroupRequest) String() string

type DeleteWaitGroupResponse 

type DeleteWaitGroupResponse struct {
	// contains filtered or unexported fields
}

func (*DeleteWaitGroupResponse) Descriptor deprecated 

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

Deprecated: Use DeleteWaitGroupResponse.ProtoReflect.Descriptor instead.

func (*DeleteWaitGroupResponse) ProtoMessage 

func (*DeleteWaitGroupResponse) ProtoMessage()

func (*DeleteWaitGroupResponse) ProtoReflect 

func (x *DeleteWaitGroupResponse) ProtoReflect() protoreflect.Message

func (*DeleteWaitGroupResponse) Reset 

func (x *DeleteWaitGroupResponse) Reset()

func (*DeleteWaitGroupResponse) String 

func (x *DeleteWaitGroupResponse) String() string

type GetBarrierByNameRequest 

type GetBarrierByNameRequest struct {
	NamespaceId *NamespaceId `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	BarrierName string       `protobuf:"bytes,2,opt,name=barrier_name,json=barrierName,proto3" json:"barrier_name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetBarrierByNameRequest) Descriptor deprecated 

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

Deprecated: Use GetBarrierByNameRequest.ProtoReflect.Descriptor instead.

func (*GetBarrierByNameRequest) GetBarrierName 

func (x *GetBarrierByNameRequest) GetBarrierName() string

func (*GetBarrierByNameRequest) GetNamespaceId 

func (x *GetBarrierByNameRequest) GetNamespaceId() *NamespaceId

func (*GetBarrierByNameRequest) ProtoMessage 

func (*GetBarrierByNameRequest) ProtoMessage()

func (*GetBarrierByNameRequest) ProtoReflect 

func (x *GetBarrierByNameRequest) ProtoReflect() protoreflect.Message

func (*GetBarrierByNameRequest) Reset 

func (x *GetBarrierByNameRequest) Reset()

func (*GetBarrierByNameRequest) String 

func (x *GetBarrierByNameRequest) String() string

type GetBarrierByNameResponse 

type GetBarrierByNameResponse struct {
	Barrier *Barrier `protobuf:"bytes,1,opt,name=barrier,proto3" json:"barrier,omitempty"`
	// contains filtered or unexported fields
}

func (*GetBarrierByNameResponse) Descriptor deprecated 

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

Deprecated: Use GetBarrierByNameResponse.ProtoReflect.Descriptor instead.

func (*GetBarrierByNameResponse) GetBarrier 

func (x *GetBarrierByNameResponse) GetBarrier() *Barrier

func (*GetBarrierByNameResponse) ProtoMessage 

func (*GetBarrierByNameResponse) ProtoMessage()

func (*GetBarrierByNameResponse) ProtoReflect 

func (x *GetBarrierByNameResponse) ProtoReflect() protoreflect.Message

func (*GetBarrierByNameResponse) Reset 

func (x *GetBarrierByNameResponse) Reset()

func (*GetBarrierByNameResponse) String 

func (x *GetBarrierByNameResponse) String() string

type GetBarrierRequest 

type GetBarrierRequest struct {
	BarrierId *BarrierId `protobuf:"bytes,1,opt,name=barrier_id,json=barrierId,proto3" json:"barrier_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetBarrierRequest) Descriptor deprecated 

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

Deprecated: Use GetBarrierRequest.ProtoReflect.Descriptor instead.

func (*GetBarrierRequest) GetBarrierId 

func (x *GetBarrierRequest) GetBarrierId() *BarrierId

func (*GetBarrierRequest) ProtoMessage 

func (*GetBarrierRequest) ProtoMessage()

func (*GetBarrierRequest) ProtoReflect 

func (x *GetBarrierRequest) ProtoReflect() protoreflect.Message

func (*GetBarrierRequest) Reset 

func (x *GetBarrierRequest) Reset()

func (*GetBarrierRequest) String 

func (x *GetBarrierRequest) String() string

type GetBarrierResponse 

type GetBarrierResponse struct {
	Barrier *Barrier `protobuf:"bytes,1,opt,name=barrier,proto3" json:"barrier,omitempty"`
	// contains filtered or unexported fields
}

func (*GetBarrierResponse) Descriptor deprecated 

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

Deprecated: Use GetBarrierResponse.ProtoReflect.Descriptor instead.

func (*GetBarrierResponse) GetBarrier 

func (x *GetBarrierResponse) GetBarrier() *Barrier

func (*GetBarrierResponse) ProtoMessage 

func (*GetBarrierResponse) ProtoMessage()

func (*GetBarrierResponse) ProtoReflect 

func (x *GetBarrierResponse) ProtoReflect() protoreflect.Message

func (*GetBarrierResponse) Reset 

func (x *GetBarrierResponse) Reset()

func (*GetBarrierResponse) String 

func (x *GetBarrierResponse) String() string

type GetLockRequest 

type GetLockRequest struct {
	LockId *LockId `protobuf:"bytes,1,opt,name=lock_id,json=lockId,proto3" json:"lock_id,omitempty"`
	Now    int64   `protobuf:"varint,2,opt,name=now,proto3" json:"now,omitempty"`
	// contains filtered or unexported fields
}

func (*GetLockRequest) Descriptor deprecated 

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

Deprecated: Use GetLockRequest.ProtoReflect.Descriptor instead.

func (*GetLockRequest) GetLockId 

func (x *GetLockRequest) GetLockId() *LockId

func (*GetLockRequest) GetNow 

func (x *GetLockRequest) GetNow() int64

func (*GetLockRequest) ProtoMessage 

func (*GetLockRequest) ProtoMessage()

func (*GetLockRequest) ProtoReflect 

func (x *GetLockRequest) ProtoReflect() protoreflect.Message

func (*GetLockRequest) Reset 

func (x *GetLockRequest) Reset()

func (*GetLockRequest) String 

func (x *GetLockRequest) String() string

type GetLockResponse 

type GetLockResponse struct {
	Lock *Lock `protobuf:"bytes,1,opt,name=lock,proto3" json:"lock,omitempty"`
	// contains filtered or unexported fields
}

func (*GetLockResponse) Descriptor deprecated 

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

Deprecated: Use GetLockResponse.ProtoReflect.Descriptor instead.

func (*GetLockResponse) GetLock 

func (x *GetLockResponse) GetLock() *Lock

func (*GetLockResponse) ProtoMessage 

func (*GetLockResponse) ProtoMessage()

func (*GetLockResponse) ProtoReflect 

func (x *GetLockResponse) ProtoReflect() protoreflect.Message

func (*GetLockResponse) Reset 

func (x *GetLockResponse) Reset()

func (*GetLockResponse) String 

func (x *GetLockResponse) String() string

type GetNamespaceByNameRequest 

type GetNamespaceByNameRequest struct {
	AccountId     uint64 `protobuf:"varint,1,opt,name=account_id,json=accountId,proto3" json:"account_id,omitempty"`
	NamespaceName string `protobuf:"bytes,2,opt,name=namespace_name,json=namespaceName,proto3" json:"namespace_name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetNamespaceByNameRequest) Descriptor deprecated 

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

Deprecated: Use GetNamespaceByNameRequest.ProtoReflect.Descriptor instead.

func (*GetNamespaceByNameRequest) GetAccountId 

func (x *GetNamespaceByNameRequest) GetAccountId() uint64

func (*GetNamespaceByNameRequest) GetNamespaceName 

func (x *GetNamespaceByNameRequest) GetNamespaceName() string

func (*GetNamespaceByNameRequest) ProtoMessage 

func (*GetNamespaceByNameRequest) ProtoMessage()

func (*GetNamespaceByNameRequest) ProtoReflect 

func (x *GetNamespaceByNameRequest) ProtoReflect() protoreflect.Message

func (*GetNamespaceByNameRequest) Reset 

func (x *GetNamespaceByNameRequest) Reset()

func (*GetNamespaceByNameRequest) String 

func (x *GetNamespaceByNameRequest) String() string

type GetNamespaceByNameResponse 

type GetNamespaceByNameResponse struct {
	Namespace *Namespace `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

func (*GetNamespaceByNameResponse) Descriptor deprecated 

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

Deprecated: Use GetNamespaceByNameResponse.ProtoReflect.Descriptor instead.

func (*GetNamespaceByNameResponse) GetNamespace 

func (x *GetNamespaceByNameResponse) GetNamespace() *Namespace

func (*GetNamespaceByNameResponse) ProtoMessage 

func (*GetNamespaceByNameResponse) ProtoMessage()

func (*GetNamespaceByNameResponse) ProtoReflect 

func (x *GetNamespaceByNameResponse) ProtoReflect() protoreflect.Message

func (*GetNamespaceByNameResponse) Reset 

func (x *GetNamespaceByNameResponse) Reset()

func (*GetNamespaceByNameResponse) String 

func (x *GetNamespaceByNameResponse) String() string

type GetNamespaceRequest 

type GetNamespaceRequest struct {
	NamespaceId *NamespaceId `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetNamespaceRequest) Descriptor deprecated 

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

Deprecated: Use GetNamespaceRequest.ProtoReflect.Descriptor instead.

func (*GetNamespaceRequest) GetNamespaceId 

func (x *GetNamespaceRequest) GetNamespaceId() *NamespaceId

func (*GetNamespaceRequest) ProtoMessage 

func (*GetNamespaceRequest) ProtoMessage()

func (*GetNamespaceRequest) ProtoReflect 

func (x *GetNamespaceRequest) ProtoReflect() protoreflect.Message

func (*GetNamespaceRequest) Reset 

func (x *GetNamespaceRequest) Reset()

func (*GetNamespaceRequest) String 

func (x *GetNamespaceRequest) String() string

type GetNamespaceResponse 

type GetNamespaceResponse struct {
	Namespace *Namespace `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

func (*GetNamespaceResponse) Descriptor deprecated 

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

Deprecated: Use GetNamespaceResponse.ProtoReflect.Descriptor instead.

func (*GetNamespaceResponse) GetNamespace 

func (x *GetNamespaceResponse) GetNamespace() *Namespace

func (*GetNamespaceResponse) ProtoMessage 

func (*GetNamespaceResponse) ProtoMessage()

func (*GetNamespaceResponse) ProtoReflect 

func (x *GetNamespaceResponse) ProtoReflect() protoreflect.Message

func (*GetNamespaceResponse) Reset 

func (x *GetNamespaceResponse) Reset()

func (*GetNamespaceResponse) String 

func (x *GetNamespaceResponse) String() string

type GetSemaphoreByNameRequest 

type GetSemaphoreByNameRequest struct {
	NamespaceId   *NamespaceId `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	SemaphoreName string       `protobuf:"bytes,2,opt,name=semaphore_name,json=semaphoreName,proto3" json:"semaphore_name,omitempty"`
	Now           int64        `protobuf:"varint,3,opt,name=now,proto3" json:"now,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSemaphoreByNameRequest) Descriptor deprecated 

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

Deprecated: Use GetSemaphoreByNameRequest.ProtoReflect.Descriptor instead.

func (*GetSemaphoreByNameRequest) GetNamespaceId 

func (x *GetSemaphoreByNameRequest) GetNamespaceId() *NamespaceId

func (*GetSemaphoreByNameRequest) GetNow 

func (x *GetSemaphoreByNameRequest) GetNow() int64

func (*GetSemaphoreByNameRequest) GetSemaphoreName 

func (x *GetSemaphoreByNameRequest) GetSemaphoreName() string

func (*GetSemaphoreByNameRequest) ProtoMessage 

func (*GetSemaphoreByNameRequest) ProtoMessage()

func (*GetSemaphoreByNameRequest) ProtoReflect 

func (x *GetSemaphoreByNameRequest) ProtoReflect() protoreflect.Message

func (*GetSemaphoreByNameRequest) Reset 

func (x *GetSemaphoreByNameRequest) Reset()

func (*GetSemaphoreByNameRequest) String 

func (x *GetSemaphoreByNameRequest) String() string

type GetSemaphoreByNameResponse 

type GetSemaphoreByNameResponse struct {
	Semaphore *Semaphore `protobuf:"bytes,1,opt,name=semaphore,proto3" json:"semaphore,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSemaphoreByNameResponse) Descriptor deprecated 

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

Deprecated: Use GetSemaphoreByNameResponse.ProtoReflect.Descriptor instead.

func (*GetSemaphoreByNameResponse) GetSemaphore 

func (x *GetSemaphoreByNameResponse) GetSemaphore() *Semaphore

func (*GetSemaphoreByNameResponse) ProtoMessage 

func (*GetSemaphoreByNameResponse) ProtoMessage()

func (*GetSemaphoreByNameResponse) ProtoReflect 

func (x *GetSemaphoreByNameResponse) ProtoReflect() protoreflect.Message

func (*GetSemaphoreByNameResponse) Reset 

func (x *GetSemaphoreByNameResponse) Reset()

func (*GetSemaphoreByNameResponse) String 

func (x *GetSemaphoreByNameResponse) String() string

type GetSemaphoreRequest 

type GetSemaphoreRequest struct {
	SemaphoreId *SemaphoreId `protobuf:"bytes,1,opt,name=semaphore_id,json=semaphoreId,proto3" json:"semaphore_id,omitempty"`
	Now         int64        `protobuf:"varint,2,opt,name=now,proto3" json:"now,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSemaphoreRequest) Descriptor deprecated 

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

Deprecated: Use GetSemaphoreRequest.ProtoReflect.Descriptor instead.

func (*GetSemaphoreRequest) GetNow 

func (x *GetSemaphoreRequest) GetNow() int64

func (*GetSemaphoreRequest) GetSemaphoreId 

func (x *GetSemaphoreRequest) GetSemaphoreId() *SemaphoreId

func (*GetSemaphoreRequest) ProtoMessage 

func (*GetSemaphoreRequest) ProtoMessage()

func (*GetSemaphoreRequest) ProtoReflect 

func (x *GetSemaphoreRequest) ProtoReflect() protoreflect.Message

func (*GetSemaphoreRequest) Reset 

func (x *GetSemaphoreRequest) Reset()

func (*GetSemaphoreRequest) String 

func (x *GetSemaphoreRequest) String() string

type GetSemaphoreResponse 

type GetSemaphoreResponse struct {
	Semaphore *Semaphore `protobuf:"bytes,1,opt,name=semaphore,proto3" json:"semaphore,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSemaphoreResponse) Descriptor deprecated 

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

Deprecated: Use GetSemaphoreResponse.ProtoReflect.Descriptor instead.

func (*GetSemaphoreResponse) GetSemaphore 

func (x *GetSemaphoreResponse) GetSemaphore() *Semaphore

func (*GetSemaphoreResponse) ProtoMessage 

func (*GetSemaphoreResponse) ProtoMessage()

func (*GetSemaphoreResponse) ProtoReflect 

func (x *GetSemaphoreResponse) ProtoReflect() protoreflect.Message

func (*GetSemaphoreResponse) Reset 

func (x *GetSemaphoreResponse) Reset()

func (*GetSemaphoreResponse) String 

func (x *GetSemaphoreResponse) String() string

type GetWaitGroupByNameRequest 

type GetWaitGroupByNameRequest struct {
	NamespaceId   *NamespaceId `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	WaitGroupName string       `protobuf:"bytes,2,opt,name=wait_group_name,json=waitGroupName,proto3" json:"wait_group_name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetWaitGroupByNameRequest) Descriptor deprecated 

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

Deprecated: Use GetWaitGroupByNameRequest.ProtoReflect.Descriptor instead.

func (*GetWaitGroupByNameRequest) GetNamespaceId 

func (x *GetWaitGroupByNameRequest) GetNamespaceId() *NamespaceId

func (*GetWaitGroupByNameRequest) GetWaitGroupName 

func (x *GetWaitGroupByNameRequest) GetWaitGroupName() string

func (*GetWaitGroupByNameRequest) ProtoMessage 

func (*GetWaitGroupByNameRequest) ProtoMessage()

func (*GetWaitGroupByNameRequest) ProtoReflect 

func (x *GetWaitGroupByNameRequest) ProtoReflect() protoreflect.Message

func (*GetWaitGroupByNameRequest) Reset 

func (x *GetWaitGroupByNameRequest) Reset()

func (*GetWaitGroupByNameRequest) String 

func (x *GetWaitGroupByNameRequest) String() string

type GetWaitGroupByNameResponse 

type GetWaitGroupByNameResponse struct {
	WaitGroup *WaitGroup `protobuf:"bytes,1,opt,name=wait_group,json=waitGroup,proto3" json:"wait_group,omitempty"`
	// contains filtered or unexported fields
}

func (*GetWaitGroupByNameResponse) Descriptor deprecated 

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

Deprecated: Use GetWaitGroupByNameResponse.ProtoReflect.Descriptor instead.

func (*GetWaitGroupByNameResponse) GetWaitGroup 

func (x *GetWaitGroupByNameResponse) GetWaitGroup() *WaitGroup

func (*GetWaitGroupByNameResponse) ProtoMessage 

func (*GetWaitGroupByNameResponse) ProtoMessage()

func (*GetWaitGroupByNameResponse) ProtoReflect 

func (x *GetWaitGroupByNameResponse) ProtoReflect() protoreflect.Message

func (*GetWaitGroupByNameResponse) Reset 

func (x *GetWaitGroupByNameResponse) Reset()

func (*GetWaitGroupByNameResponse) String 

func (x *GetWaitGroupByNameResponse) String() string

type GetWaitGroupRequest 

type GetWaitGroupRequest struct {
	WaitGroupId *WaitGroupId `protobuf:"bytes,1,opt,name=wait_group_id,json=waitGroupId,proto3" json:"wait_group_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetWaitGroupRequest) Descriptor deprecated 

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

Deprecated: Use GetWaitGroupRequest.ProtoReflect.Descriptor instead.

func (*GetWaitGroupRequest) GetWaitGroupId 

func (x *GetWaitGroupRequest) GetWaitGroupId() *WaitGroupId

func (*GetWaitGroupRequest) ProtoMessage 

func (*GetWaitGroupRequest) ProtoMessage()

func (*GetWaitGroupRequest) ProtoReflect 

func (x *GetWaitGroupRequest) ProtoReflect() protoreflect.Message

func (*GetWaitGroupRequest) Reset 

func (x *GetWaitGroupRequest) Reset()

func (*GetWaitGroupRequest) String 

func (x *GetWaitGroupRequest) String() string

type GetWaitGroupResponse 

type GetWaitGroupResponse struct {
	WaitGroup *WaitGroup `protobuf:"bytes,1,opt,name=wait_group,json=waitGroup,proto3" json:"wait_group,omitempty"`
	// contains filtered or unexported fields
}

func (*GetWaitGroupResponse) Descriptor deprecated 

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

Deprecated: Use GetWaitGroupResponse.ProtoReflect.Descriptor instead.

func (*GetWaitGroupResponse) GetWaitGroup 

func (x *GetWaitGroupResponse) GetWaitGroup() *WaitGroup

func (*GetWaitGroupResponse) ProtoMessage 

func (*GetWaitGroupResponse) ProtoMessage()

func (*GetWaitGroupResponse) ProtoReflect 

func (x *GetWaitGroupResponse) ProtoReflect() protoreflect.Message

func (*GetWaitGroupResponse) Reset 

func (x *GetWaitGroupResponse) Reset()

func (*GetWaitGroupResponse) String 

func (x *GetWaitGroupResponse) String() string

type GrackleReadRequest 

type GrackleReadRequest struct {

	// Types that are valid to be assigned to Request:
	//
	//	*GrackleReadRequest_GetSemaphoreRequest
	//	*GrackleReadRequest_GetSemaphoreByNameRequest
	//	*GrackleReadRequest_ListSemaphoresRequest
	//	*GrackleReadRequest_ListSemaphoreHoldersRequest
	//	*GrackleReadRequest_GetWaitGroupRequest
	//	*GrackleReadRequest_GetWaitGroupByNameRequest
	//	*GrackleReadRequest_ListWaitGroupsRequest
	//	*GrackleReadRequest_ListWaitGroupJobsRequest
	//	*GrackleReadRequest_GetNamespaceRequest
	//	*GrackleReadRequest_GetNamespaceByNameRequest
	//	*GrackleReadRequest_ListNamespacesRequest
	//	*GrackleReadRequest_ListLocksRequest
	//	*GrackleReadRequest_GetBarrierRequest
	//	*GrackleReadRequest_GetBarrierByNameRequest
	//	*GrackleReadRequest_ListBarriersRequest
	//	*GrackleReadRequest_ListBarrierParticipantsRequest
	Request isGrackleReadRequest_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

func (*GrackleReadRequest) Descriptor deprecated 

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

Deprecated: Use GrackleReadRequest.ProtoReflect.Descriptor instead.

func (*GrackleReadRequest) GetGetBarrierByNameRequest 

func (x *GrackleReadRequest) GetGetBarrierByNameRequest() *GetBarrierByNameRequest

func (*GrackleReadRequest) GetGetBarrierRequest 

func (x *GrackleReadRequest) GetGetBarrierRequest() *GetBarrierRequest

func (*GrackleReadRequest) GetGetNamespaceByNameRequest 

func (x *GrackleReadRequest) GetGetNamespaceByNameRequest() *GetNamespaceByNameRequest

func (*GrackleReadRequest) GetGetNamespaceRequest 

func (x *GrackleReadRequest) GetGetNamespaceRequest() *GetNamespaceRequest

func (*GrackleReadRequest) GetGetSemaphoreByNameRequest 

func (x *GrackleReadRequest) GetGetSemaphoreByNameRequest() *GetSemaphoreByNameRequest

func (*GrackleReadRequest) GetGetSemaphoreRequest 

func (x *GrackleReadRequest) GetGetSemaphoreRequest() *GetSemaphoreRequest

func (*GrackleReadRequest) GetGetWaitGroupByNameRequest 

func (x *GrackleReadRequest) GetGetWaitGroupByNameRequest() *GetWaitGroupByNameRequest

func (*GrackleReadRequest) GetGetWaitGroupRequest 

func (x *GrackleReadRequest) GetGetWaitGroupRequest() *GetWaitGroupRequest

func (*GrackleReadRequest) GetListBarrierParticipantsRequest 

func (x *GrackleReadRequest) GetListBarrierParticipantsRequest() *ListBarrierParticipantsRequest

func (*GrackleReadRequest) GetListBarriersRequest 

func (x *GrackleReadRequest) GetListBarriersRequest() *ListBarriersRequest

func (*GrackleReadRequest) GetListLocksRequest 

func (x *GrackleReadRequest) GetListLocksRequest() *ListLocksRequest

func (*GrackleReadRequest) GetListNamespacesRequest 

func (x *GrackleReadRequest) GetListNamespacesRequest() *ListNamespacesRequest

func (*GrackleReadRequest) GetListSemaphoreHoldersRequest 

func (x *GrackleReadRequest) GetListSemaphoreHoldersRequest() *ListSemaphoreHoldersRequest

func (*GrackleReadRequest) GetListSemaphoresRequest 

func (x *GrackleReadRequest) GetListSemaphoresRequest() *ListSemaphoresRequest

func (*GrackleReadRequest) GetListWaitGroupJobsRequest 

func (x *GrackleReadRequest) GetListWaitGroupJobsRequest() *ListWaitGroupJobsRequest

func (*GrackleReadRequest) GetListWaitGroupsRequest 

func (x *GrackleReadRequest) GetListWaitGroupsRequest() *ListWaitGroupsRequest

func (*GrackleReadRequest) GetRequest 

func (x *GrackleReadRequest) GetRequest() isGrackleReadRequest_Request

func (*GrackleReadRequest) ProtoMessage 

func (*GrackleReadRequest) ProtoMessage()

func (*GrackleReadRequest) ProtoReflect 

func (x *GrackleReadRequest) ProtoReflect() protoreflect.Message

func (*GrackleReadRequest) Reset 

func (x *GrackleReadRequest) Reset()

func (*GrackleReadRequest) String 

func (x *GrackleReadRequest) String() string

type GrackleReadRequest_GetBarrierByNameRequest 

type GrackleReadRequest_GetBarrierByNameRequest struct {
	GetBarrierByNameRequest *GetBarrierByNameRequest `protobuf:"bytes,14,opt,name=get_barrier_by_name_request,json=getBarrierByNameRequest,proto3,oneof"`
}

type GrackleReadRequest_GetBarrierRequest 

type GrackleReadRequest_GetBarrierRequest struct {
	GetBarrierRequest *GetBarrierRequest `protobuf:"bytes,13,opt,name=get_barrier_request,json=getBarrierRequest,proto3,oneof"`
}

type GrackleReadRequest_GetNamespaceByNameRequest 

type GrackleReadRequest_GetNamespaceByNameRequest struct {
	GetNamespaceByNameRequest *GetNamespaceByNameRequest `protobuf:"bytes,10,opt,name=get_namespace_by_name_request,json=getNamespaceByNameRequest,proto3,oneof"`
}

type GrackleReadRequest_GetNamespaceRequest 

type GrackleReadRequest_GetNamespaceRequest struct {
	GetNamespaceRequest *GetNamespaceRequest `protobuf:"bytes,9,opt,name=get_namespace_request,json=getNamespaceRequest,proto3,oneof"`
}

type GrackleReadRequest_GetSemaphoreByNameRequest 

type GrackleReadRequest_GetSemaphoreByNameRequest struct {
	GetSemaphoreByNameRequest *GetSemaphoreByNameRequest `protobuf:"bytes,2,opt,name=get_semaphore_by_name_request,json=getSemaphoreByNameRequest,proto3,oneof"`
}

type GrackleReadRequest_GetSemaphoreRequest 

type GrackleReadRequest_GetSemaphoreRequest struct {
	GetSemaphoreRequest *GetSemaphoreRequest `protobuf:"bytes,1,opt,name=get_semaphore_request,json=getSemaphoreRequest,proto3,oneof"`
}

type GrackleReadRequest_GetWaitGroupByNameRequest 

type GrackleReadRequest_GetWaitGroupByNameRequest struct {
	GetWaitGroupByNameRequest *GetWaitGroupByNameRequest `protobuf:"bytes,6,opt,name=get_wait_group_by_name_request,json=getWaitGroupByNameRequest,proto3,oneof"`
}

type GrackleReadRequest_GetWaitGroupRequest 

type GrackleReadRequest_GetWaitGroupRequest struct {
	GetWaitGroupRequest *GetWaitGroupRequest `protobuf:"bytes,5,opt,name=get_wait_group_request,json=getWaitGroupRequest,proto3,oneof"`
}

type GrackleReadRequest_ListBarrierParticipantsRequest 

type GrackleReadRequest_ListBarrierParticipantsRequest struct {
	ListBarrierParticipantsRequest *ListBarrierParticipantsRequest `protobuf:"bytes,16,opt,name=list_barrier_participants_request,json=listBarrierParticipantsRequest,proto3,oneof"`
}

type GrackleReadRequest_ListBarriersRequest 

type GrackleReadRequest_ListBarriersRequest struct {
	ListBarriersRequest *ListBarriersRequest `protobuf:"bytes,15,opt,name=list_barriers_request,json=listBarriersRequest,proto3,oneof"`
}

type GrackleReadRequest_ListLocksRequest 

type GrackleReadRequest_ListLocksRequest struct {
	ListLocksRequest *ListLocksRequest `protobuf:"bytes,12,opt,name=list_locks_request,json=listLocksRequest,proto3,oneof"`
}

type GrackleReadRequest_ListNamespacesRequest 

type GrackleReadRequest_ListNamespacesRequest struct {
	ListNamespacesRequest *ListNamespacesRequest `protobuf:"bytes,11,opt,name=list_namespaces_request,json=listNamespacesRequest,proto3,oneof"`
}

type GrackleReadRequest_ListSemaphoreHoldersRequest 

type GrackleReadRequest_ListSemaphoreHoldersRequest struct {
	ListSemaphoreHoldersRequest *ListSemaphoreHoldersRequest `protobuf:"bytes,4,opt,name=list_semaphore_holders_request,json=listSemaphoreHoldersRequest,proto3,oneof"`
}

type GrackleReadRequest_ListSemaphoresRequest 

type GrackleReadRequest_ListSemaphoresRequest struct {
	ListSemaphoresRequest *ListSemaphoresRequest `protobuf:"bytes,3,opt,name=list_semaphores_request,json=listSemaphoresRequest,proto3,oneof"`
}

type GrackleReadRequest_ListWaitGroupJobsRequest 

type GrackleReadRequest_ListWaitGroupJobsRequest struct {
	ListWaitGroupJobsRequest *ListWaitGroupJobsRequest `protobuf:"bytes,8,opt,name=list_wait_group_jobs_request,json=listWaitGroupJobsRequest,proto3,oneof"`
}

type GrackleReadRequest_ListWaitGroupsRequest 

type GrackleReadRequest_ListWaitGroupsRequest struct {
	ListWaitGroupsRequest *ListWaitGroupsRequest `protobuf:"bytes,7,opt,name=list_wait_groups_request,json=listWaitGroupsRequest,proto3,oneof"`
}

type GrackleReadResponse 

type GrackleReadResponse struct {

	// Types that are valid to be assigned to Response:
	//
	//	*GrackleReadResponse_GetSemaphoreResponse
	//	*GrackleReadResponse_GetSemaphoreByNameResponse
	//	*GrackleReadResponse_ListSemaphoresResponse
	//	*GrackleReadResponse_ListSemaphoreHoldersResponse
	//	*GrackleReadResponse_GetWaitGroupResponse
	//	*GrackleReadResponse_GetWaitGroupByNameResponse
	//	*GrackleReadResponse_ListWaitGroupsResponse
	//	*GrackleReadResponse_ListWaitGroupJobsResponse
	//	*GrackleReadResponse_GetNamespaceResponse
	//	*GrackleReadResponse_GetNamespaceByNameResponse
	//	*GrackleReadResponse_ListNamespacesResponse
	//	*GrackleReadResponse_ListLocksResponse
	//	*GrackleReadResponse_GetBarrierResponse
	//	*GrackleReadResponse_GetBarrierByNameResponse
	//	*GrackleReadResponse_ListBarriersResponse
	//	*GrackleReadResponse_ListBarrierParticipantsResponse
	Response isGrackleReadResponse_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

func (*GrackleReadResponse) Descriptor deprecated 

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

Deprecated: Use GrackleReadResponse.ProtoReflect.Descriptor instead.

func (*GrackleReadResponse) GetGetBarrierByNameResponse 

func (x *GrackleReadResponse) GetGetBarrierByNameResponse() *GetBarrierByNameResponse

func (*GrackleReadResponse) GetGetBarrierResponse 

func (x *GrackleReadResponse) GetGetBarrierResponse() *GetBarrierResponse

func (*GrackleReadResponse) GetGetNamespaceByNameResponse 

func (x *GrackleReadResponse) GetGetNamespaceByNameResponse() *GetNamespaceByNameResponse

func (*GrackleReadResponse) GetGetNamespaceResponse 

func (x *GrackleReadResponse) GetGetNamespaceResponse() *GetNamespaceResponse

func (*GrackleReadResponse) GetGetSemaphoreByNameResponse 

func (x *GrackleReadResponse) GetGetSemaphoreByNameResponse() *GetSemaphoreByNameResponse

func (*GrackleReadResponse) GetGetSemaphoreResponse 

func (x *GrackleReadResponse) GetGetSemaphoreResponse() *GetSemaphoreResponse

func (*GrackleReadResponse) GetGetWaitGroupByNameResponse 

func (x *GrackleReadResponse) GetGetWaitGroupByNameResponse() *GetWaitGroupByNameResponse

func (*GrackleReadResponse) GetGetWaitGroupResponse 

func (x *GrackleReadResponse) GetGetWaitGroupResponse() *GetWaitGroupResponse

func (*GrackleReadResponse) GetListBarrierParticipantsResponse 

func (x *GrackleReadResponse) GetListBarrierParticipantsResponse() *ListBarrierParticipantsResponse

func (*GrackleReadResponse) GetListBarriersResponse 

func (x *GrackleReadResponse) GetListBarriersResponse() *ListBarriersResponse

func (*GrackleReadResponse) GetListLocksResponse 

func (x *GrackleReadResponse) GetListLocksResponse() *ListLocksResponse

func (*GrackleReadResponse) GetListNamespacesResponse 

func (x *GrackleReadResponse) GetListNamespacesResponse() *ListNamespacesResponse

func (*GrackleReadResponse) GetListSemaphoreHoldersResponse 

func (x *GrackleReadResponse) GetListSemaphoreHoldersResponse() *ListSemaphoreHoldersResponse

func (*GrackleReadResponse) GetListSemaphoresResponse 

func (x *GrackleReadResponse) GetListSemaphoresResponse() *ListSemaphoresResponse

func (*GrackleReadResponse) GetListWaitGroupJobsResponse 

func (x *GrackleReadResponse) GetListWaitGroupJobsResponse() *ListWaitGroupJobsResponse

func (*GrackleReadResponse) GetListWaitGroupsResponse 

func (x *GrackleReadResponse) GetListWaitGroupsResponse() *ListWaitGroupsResponse

func (*GrackleReadResponse) GetResponse 

func (x *GrackleReadResponse) GetResponse() isGrackleReadResponse_Response

func (*GrackleReadResponse) ProtoMessage 

func (*GrackleReadResponse) ProtoMessage()

func (*GrackleReadResponse) ProtoReflect 

func (x *GrackleReadResponse) ProtoReflect() protoreflect.Message

func (*GrackleReadResponse) Reset 

func (x *GrackleReadResponse) Reset()

func (*GrackleReadResponse) String 

func (x *GrackleReadResponse) String() string

type GrackleReadResponse_GetBarrierByNameResponse 

type GrackleReadResponse_GetBarrierByNameResponse struct {
	GetBarrierByNameResponse *GetBarrierByNameResponse `protobuf:"bytes,14,opt,name=get_barrier_by_name_response,json=getBarrierByNameResponse,proto3,oneof"`
}

type GrackleReadResponse_GetBarrierResponse 

type GrackleReadResponse_GetBarrierResponse struct {
	GetBarrierResponse *GetBarrierResponse `protobuf:"bytes,13,opt,name=get_barrier_response,json=getBarrierResponse,proto3,oneof"`
}

type GrackleReadResponse_GetNamespaceByNameResponse 

type GrackleReadResponse_GetNamespaceByNameResponse struct {
	GetNamespaceByNameResponse *GetNamespaceByNameResponse `protobuf:"bytes,10,opt,name=get_namespace_by_name_response,json=getNamespaceByNameResponse,proto3,oneof"`
}

type GrackleReadResponse_GetNamespaceResponse 

type GrackleReadResponse_GetNamespaceResponse struct {
	GetNamespaceResponse *GetNamespaceResponse `protobuf:"bytes,9,opt,name=get_namespace_response,json=getNamespaceResponse,proto3,oneof"`
}

type GrackleReadResponse_GetSemaphoreByNameResponse 

type GrackleReadResponse_GetSemaphoreByNameResponse struct {
	GetSemaphoreByNameResponse *GetSemaphoreByNameResponse `protobuf:"bytes,2,opt,name=get_semaphore_by_name_response,json=getSemaphoreByNameResponse,proto3,oneof"`
}

type GrackleReadResponse_GetSemaphoreResponse 

type GrackleReadResponse_GetSemaphoreResponse struct {
	GetSemaphoreResponse *GetSemaphoreResponse `protobuf:"bytes,1,opt,name=get_semaphore_response,json=getSemaphoreResponse,proto3,oneof"`
}

type GrackleReadResponse_GetWaitGroupByNameResponse 

type GrackleReadResponse_GetWaitGroupByNameResponse struct {
	GetWaitGroupByNameResponse *GetWaitGroupByNameResponse `protobuf:"bytes,6,opt,name=get_wait_group_by_name_response,json=getWaitGroupByNameResponse,proto3,oneof"`
}

type GrackleReadResponse_GetWaitGroupResponse 

type GrackleReadResponse_GetWaitGroupResponse struct {
	GetWaitGroupResponse *GetWaitGroupResponse `protobuf:"bytes,5,opt,name=get_wait_group_response,json=getWaitGroupResponse,proto3,oneof"`
}

type GrackleReadResponse_ListBarrierParticipantsResponse 

type GrackleReadResponse_ListBarrierParticipantsResponse struct {
	ListBarrierParticipantsResponse *ListBarrierParticipantsResponse `protobuf:"bytes,16,opt,name=list_barrier_participants_response,json=listBarrierParticipantsResponse,proto3,oneof"`
}

type GrackleReadResponse_ListBarriersResponse 

type GrackleReadResponse_ListBarriersResponse struct {
	ListBarriersResponse *ListBarriersResponse `protobuf:"bytes,15,opt,name=list_barriers_response,json=listBarriersResponse,proto3,oneof"`
}

type GrackleReadResponse_ListLocksResponse 

type GrackleReadResponse_ListLocksResponse struct {
	ListLocksResponse *ListLocksResponse `protobuf:"bytes,12,opt,name=list_locks_response,json=listLocksResponse,proto3,oneof"`
}

type GrackleReadResponse_ListNamespacesResponse 

type GrackleReadResponse_ListNamespacesResponse struct {
	ListNamespacesResponse *ListNamespacesResponse `protobuf:"bytes,11,opt,name=list_namespaces_response,json=listNamespacesResponse,proto3,oneof"`
}

type GrackleReadResponse_ListSemaphoreHoldersResponse 

type GrackleReadResponse_ListSemaphoreHoldersResponse struct {
	ListSemaphoreHoldersResponse *ListSemaphoreHoldersResponse `protobuf:"bytes,4,opt,name=list_semaphore_holders_response,json=listSemaphoreHoldersResponse,proto3,oneof"`
}

type GrackleReadResponse_ListSemaphoresResponse 

type GrackleReadResponse_ListSemaphoresResponse struct {
	ListSemaphoresResponse *ListSemaphoresResponse `protobuf:"bytes,3,opt,name=list_semaphores_response,json=listSemaphoresResponse,proto3,oneof"`
}

type GrackleReadResponse_ListWaitGroupJobsResponse 

type GrackleReadResponse_ListWaitGroupJobsResponse struct {
	ListWaitGroupJobsResponse *ListWaitGroupJobsResponse `protobuf:"bytes,8,opt,name=list_wait_group_jobs_response,json=listWaitGroupJobsResponse,proto3,oneof"`
}

type GrackleReadResponse_ListWaitGroupsResponse 

type GrackleReadResponse_ListWaitGroupsResponse struct {
	ListWaitGroupsResponse *ListWaitGroupsResponse `protobuf:"bytes,7,opt,name=list_wait_groups_response,json=listWaitGroupsResponse,proto3,oneof"`
}

type GrackleUpdateRequest 

type GrackleUpdateRequest struct {

	// Types that are valid to be assigned to Request:
	//
	//	*GrackleUpdateRequest_CreateSemaphoreRequest
	//	*GrackleUpdateRequest_UpdateSemaphoreRequest
	//	*GrackleUpdateRequest_DeleteSemaphoreRequest
	//	*GrackleUpdateRequest_AcquireSemaphoreRequest
	//	*GrackleUpdateRequest_ReleaseSemaphoreRequest
	//	*GrackleUpdateRequest_RunSemaphoresGarbageCollectionRequest
	//	*GrackleUpdateRequest_SemaphoresDeleteNamespaceRequest
	//	*GrackleUpdateRequest_CreateWaitGroupRequest
	//	*GrackleUpdateRequest_DeleteWaitGroupRequest
	//	*GrackleUpdateRequest_AddJobsToWaitGroupRequest
	//	*GrackleUpdateRequest_CompleteJobsFromWaitGroupRequest
	//	*GrackleUpdateRequest_RunWaitGroupsGarbageCollectionRequest
	//	*GrackleUpdateRequest_WaitGroupsDeleteNamespaceRequest
	//	*GrackleUpdateRequest_AcquireLockRequest
	//	*GrackleUpdateRequest_ReleaseLockRequest
	//	*GrackleUpdateRequest_DeleteLockRequest
	//	*GrackleUpdateRequest_GetLockRequest
	//	*GrackleUpdateRequest_RunLocksGarbageCollectionRequest
	//	*GrackleUpdateRequest_LocksDeleteNamespaceRequest
	//	*GrackleUpdateRequest_CreateNamespaceRequest
	//	*GrackleUpdateRequest_UpdateNamespaceRequest
	//	*GrackleUpdateRequest_DeleteNamespaceRequest
	//	*GrackleUpdateRequest_CreateBarrierRequest
	//	*GrackleUpdateRequest_DeleteBarrierRequest
	//	*GrackleUpdateRequest_UpdateBarrierRequest
	//	*GrackleUpdateRequest_ArriveAtBarrierRequest
	//	*GrackleUpdateRequest_WaitAtBarrierRequest
	//	*GrackleUpdateRequest_RunBarriersGarbageCollectionRequest
	//	*GrackleUpdateRequest_BarriersDeleteNamespaceRequest
	Request isGrackleUpdateRequest_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

func (*GrackleUpdateRequest) Descriptor deprecated 

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

Deprecated: Use GrackleUpdateRequest.ProtoReflect.Descriptor instead.

func (*GrackleUpdateRequest) GetAcquireLockRequest 

func (x *GrackleUpdateRequest) GetAcquireLockRequest() *AcquireLockRequest

func (*GrackleUpdateRequest) GetAcquireSemaphoreRequest 

func (x *GrackleUpdateRequest) GetAcquireSemaphoreRequest() *AcquireSemaphoreRequest

func (*GrackleUpdateRequest) GetAddJobsToWaitGroupRequest 

func (x *GrackleUpdateRequest) GetAddJobsToWaitGroupRequest() *AddJobsToWaitGroupRequest

func (*GrackleUpdateRequest) GetArriveAtBarrierRequest 

func (x *GrackleUpdateRequest) GetArriveAtBarrierRequest() *ArriveAtBarrierRequest

func (*GrackleUpdateRequest) GetBarriersDeleteNamespaceRequest 

func (x *GrackleUpdateRequest) GetBarriersDeleteNamespaceRequest() *BarriersDeleteNamespaceRequest

func (*GrackleUpdateRequest) GetCompleteJobsFromWaitGroupRequest 

func (x *GrackleUpdateRequest) GetCompleteJobsFromWaitGroupRequest() *CompleteJobsFromWaitGroupRequest

func (*GrackleUpdateRequest) GetCreateBarrierRequest 

func (x *GrackleUpdateRequest) GetCreateBarrierRequest() *CreateBarrierRequest

func (*GrackleUpdateRequest) GetCreateNamespaceRequest 

func (x *GrackleUpdateRequest) GetCreateNamespaceRequest() *CreateNamespaceRequest

func (*GrackleUpdateRequest) GetCreateSemaphoreRequest 

func (x *GrackleUpdateRequest) GetCreateSemaphoreRequest() *CreateSemaphoreRequest

func (*GrackleUpdateRequest) GetCreateWaitGroupRequest 

func (x *GrackleUpdateRequest) GetCreateWaitGroupRequest() *CreateWaitGroupRequest

func (*GrackleUpdateRequest) GetDeleteBarrierRequest 

func (x *GrackleUpdateRequest) GetDeleteBarrierRequest() *DeleteBarrierRequest

func (*GrackleUpdateRequest) GetDeleteLockRequest 

func (x *GrackleUpdateRequest) GetDeleteLockRequest() *DeleteLockRequest

func (*GrackleUpdateRequest) GetDeleteNamespaceRequest 

func (x *GrackleUpdateRequest) GetDeleteNamespaceRequest() *DeleteNamespaceRequest

func (*GrackleUpdateRequest) GetDeleteSemaphoreRequest 

func (x *GrackleUpdateRequest) GetDeleteSemaphoreRequest() *DeleteSemaphoreRequest

func (*GrackleUpdateRequest) GetDeleteWaitGroupRequest 

func (x *GrackleUpdateRequest) GetDeleteWaitGroupRequest() *DeleteWaitGroupRequest

func (*GrackleUpdateRequest) GetGetLockRequest 

func (x *GrackleUpdateRequest) GetGetLockRequest() *GetLockRequest

func (*GrackleUpdateRequest) GetLocksDeleteNamespaceRequest 

func (x *GrackleUpdateRequest) GetLocksDeleteNamespaceRequest() *LocksDeleteNamespaceRequest

func (*GrackleUpdateRequest) GetReleaseLockRequest 

func (x *GrackleUpdateRequest) GetReleaseLockRequest() *ReleaseLockRequest

func (*GrackleUpdateRequest) GetReleaseSemaphoreRequest 

func (x *GrackleUpdateRequest) GetReleaseSemaphoreRequest() *ReleaseSemaphoreRequest

func (*GrackleUpdateRequest) GetRequest 

func (x *GrackleUpdateRequest) GetRequest() isGrackleUpdateRequest_Request

func (*GrackleUpdateRequest) GetRunBarriersGarbageCollectionRequest 

func (x *GrackleUpdateRequest) GetRunBarriersGarbageCollectionRequest() *RunBarriersGarbageCollectionRequest

func (*GrackleUpdateRequest) GetRunLocksGarbageCollectionRequest 

func (x *GrackleUpdateRequest) GetRunLocksGarbageCollectionRequest() *RunLocksGarbageCollectionRequest

func (*GrackleUpdateRequest) GetRunSemaphoresGarbageCollectionRequest 

func (x *GrackleUpdateRequest) GetRunSemaphoresGarbageCollectionRequest() *RunSemaphoresGarbageCollectionRequest

func (*GrackleUpdateRequest) GetRunWaitGroupsGarbageCollectionRequest 

func (x *GrackleUpdateRequest) GetRunWaitGroupsGarbageCollectionRequest() *RunWaitGroupsGarbageCollectionRequest

func (*GrackleUpdateRequest) GetSemaphoresDeleteNamespaceRequest 

func (x *GrackleUpdateRequest) GetSemaphoresDeleteNamespaceRequest() *SemaphoresDeleteNamespaceRequest

func (*GrackleUpdateRequest) GetUpdateBarrierRequest 

func (x *GrackleUpdateRequest) GetUpdateBarrierRequest() *UpdateBarrierRequest

func (*GrackleUpdateRequest) GetUpdateNamespaceRequest 

func (x *GrackleUpdateRequest) GetUpdateNamespaceRequest() *UpdateNamespaceRequest

func (*GrackleUpdateRequest) GetUpdateSemaphoreRequest 

func (x *GrackleUpdateRequest) GetUpdateSemaphoreRequest() *UpdateSemaphoreRequest

func (*GrackleUpdateRequest) GetWaitAtBarrierRequest 

func (x *GrackleUpdateRequest) GetWaitAtBarrierRequest() *WaitAtBarrierRequest

func (*GrackleUpdateRequest) GetWaitGroupsDeleteNamespaceRequest 

func (x *GrackleUpdateRequest) GetWaitGroupsDeleteNamespaceRequest() *WaitGroupsDeleteNamespaceRequest

func (*GrackleUpdateRequest) ProtoMessage 

func (*GrackleUpdateRequest) ProtoMessage()

func (*GrackleUpdateRequest) ProtoReflect 

func (x *GrackleUpdateRequest) ProtoReflect() protoreflect.Message

func (*GrackleUpdateRequest) Reset 

func (x *GrackleUpdateRequest) Reset()

func (*GrackleUpdateRequest) String 

func (x *GrackleUpdateRequest) String() string

type GrackleUpdateRequest_AcquireLockRequest 

type GrackleUpdateRequest_AcquireLockRequest struct {
	AcquireLockRequest *AcquireLockRequest `protobuf:"bytes,14,opt,name=acquire_lock_request,json=acquireLockRequest,proto3,oneof"`
}

type GrackleUpdateRequest_AcquireSemaphoreRequest 

type GrackleUpdateRequest_AcquireSemaphoreRequest struct {
	AcquireSemaphoreRequest *AcquireSemaphoreRequest `protobuf:"bytes,4,opt,name=acquire_semaphore_request,json=acquireSemaphoreRequest,proto3,oneof"`
}

type GrackleUpdateRequest_AddJobsToWaitGroupRequest 

type GrackleUpdateRequest_AddJobsToWaitGroupRequest struct {
	AddJobsToWaitGroupRequest *AddJobsToWaitGroupRequest `protobuf:"bytes,10,opt,name=add_jobs_to_wait_group_request,json=addJobsToWaitGroupRequest,proto3,oneof"`
}

type GrackleUpdateRequest_ArriveAtBarrierRequest 

type GrackleUpdateRequest_ArriveAtBarrierRequest struct {
	ArriveAtBarrierRequest *ArriveAtBarrierRequest `protobuf:"bytes,26,opt,name=arrive_at_barrier_request,json=arriveAtBarrierRequest,proto3,oneof"`
}

type GrackleUpdateRequest_BarriersDeleteNamespaceRequest 

type GrackleUpdateRequest_BarriersDeleteNamespaceRequest struct {
	BarriersDeleteNamespaceRequest *BarriersDeleteNamespaceRequest `protobuf:"bytes,29,opt,name=barriers_delete_namespace_request,json=barriersDeleteNamespaceRequest,proto3,oneof"`
}

type GrackleUpdateRequest_CompleteJobsFromWaitGroupRequest 

type GrackleUpdateRequest_CompleteJobsFromWaitGroupRequest struct {
	CompleteJobsFromWaitGroupRequest *CompleteJobsFromWaitGroupRequest `protobuf:"bytes,11,opt,name=complete_jobs_from_wait_group_request,json=completeJobsFromWaitGroupRequest,proto3,oneof"`
}

type GrackleUpdateRequest_CreateBarrierRequest 

type GrackleUpdateRequest_CreateBarrierRequest struct {
	CreateBarrierRequest *CreateBarrierRequest `protobuf:"bytes,23,opt,name=create_barrier_request,json=createBarrierRequest,proto3,oneof"`
}

type GrackleUpdateRequest_CreateNamespaceRequest 

type GrackleUpdateRequest_CreateNamespaceRequest struct {
	CreateNamespaceRequest *CreateNamespaceRequest `protobuf:"bytes,20,opt,name=create_namespace_request,json=createNamespaceRequest,proto3,oneof"`
}

type GrackleUpdateRequest_CreateSemaphoreRequest 

type GrackleUpdateRequest_CreateSemaphoreRequest struct {
	CreateSemaphoreRequest *CreateSemaphoreRequest `protobuf:"bytes,1,opt,name=create_semaphore_request,json=createSemaphoreRequest,proto3,oneof"`
}

type GrackleUpdateRequest_CreateWaitGroupRequest 

type GrackleUpdateRequest_CreateWaitGroupRequest struct {
	CreateWaitGroupRequest *CreateWaitGroupRequest `protobuf:"bytes,8,opt,name=create_wait_group_request,json=createWaitGroupRequest,proto3,oneof"`
}

type GrackleUpdateRequest_DeleteBarrierRequest 

type GrackleUpdateRequest_DeleteBarrierRequest struct {
	DeleteBarrierRequest *DeleteBarrierRequest `protobuf:"bytes,24,opt,name=delete_barrier_request,json=deleteBarrierRequest,proto3,oneof"`
}

type GrackleUpdateRequest_DeleteLockRequest 

type GrackleUpdateRequest_DeleteLockRequest struct {
	DeleteLockRequest *DeleteLockRequest `protobuf:"bytes,16,opt,name=delete_lock_request,json=deleteLockRequest,proto3,oneof"`
}

type GrackleUpdateRequest_DeleteNamespaceRequest 

type GrackleUpdateRequest_DeleteNamespaceRequest struct {
	DeleteNamespaceRequest *DeleteNamespaceRequest `protobuf:"bytes,22,opt,name=delete_namespace_request,json=deleteNamespaceRequest,proto3,oneof"`
}

type GrackleUpdateRequest_DeleteSemaphoreRequest 

type GrackleUpdateRequest_DeleteSemaphoreRequest struct {
	DeleteSemaphoreRequest *DeleteSemaphoreRequest `protobuf:"bytes,3,opt,name=delete_semaphore_request,json=deleteSemaphoreRequest,proto3,oneof"`
}

type GrackleUpdateRequest_DeleteWaitGroupRequest 

type GrackleUpdateRequest_DeleteWaitGroupRequest struct {
	DeleteWaitGroupRequest *DeleteWaitGroupRequest `protobuf:"bytes,9,opt,name=delete_wait_group_request,json=deleteWaitGroupRequest,proto3,oneof"`
}

type GrackleUpdateRequest_GetLockRequest 

type GrackleUpdateRequest_GetLockRequest struct {
	GetLockRequest *GetLockRequest `protobuf:"bytes,17,opt,name=get_lock_request,json=getLockRequest,proto3,oneof"`
}

type GrackleUpdateRequest_LocksDeleteNamespaceRequest 

type GrackleUpdateRequest_LocksDeleteNamespaceRequest struct {
	LocksDeleteNamespaceRequest *LocksDeleteNamespaceRequest `protobuf:"bytes,19,opt,name=locks_delete_namespace_request,json=locksDeleteNamespaceRequest,proto3,oneof"`
}

type GrackleUpdateRequest_ReleaseLockRequest 

type GrackleUpdateRequest_ReleaseLockRequest struct {
	ReleaseLockRequest *ReleaseLockRequest `protobuf:"bytes,15,opt,name=release_lock_request,json=releaseLockRequest,proto3,oneof"`
}

type GrackleUpdateRequest_ReleaseSemaphoreRequest 

type GrackleUpdateRequest_ReleaseSemaphoreRequest struct {
	ReleaseSemaphoreRequest *ReleaseSemaphoreRequest `protobuf:"bytes,5,opt,name=release_semaphore_request,json=releaseSemaphoreRequest,proto3,oneof"`
}

type GrackleUpdateRequest_RunBarriersGarbageCollectionRequest 

type GrackleUpdateRequest_RunBarriersGarbageCollectionRequest struct {
	RunBarriersGarbageCollectionRequest *RunBarriersGarbageCollectionRequest `protobuf:"bytes,28,opt,name=run_barriers_garbage_collection_request,json=runBarriersGarbageCollectionRequest,proto3,oneof"`
}

type GrackleUpdateRequest_RunLocksGarbageCollectionRequest 

type GrackleUpdateRequest_RunLocksGarbageCollectionRequest struct {
	RunLocksGarbageCollectionRequest *RunLocksGarbageCollectionRequest `protobuf:"bytes,18,opt,name=run_locks_garbage_collection_request,json=runLocksGarbageCollectionRequest,proto3,oneof"`
}

type GrackleUpdateRequest_RunSemaphoresGarbageCollectionRequest 

type GrackleUpdateRequest_RunSemaphoresGarbageCollectionRequest struct {
	RunSemaphoresGarbageCollectionRequest *RunSemaphoresGarbageCollectionRequest `protobuf:"bytes,6,opt,name=run_semaphores_garbage_collection_request,json=runSemaphoresGarbageCollectionRequest,proto3,oneof"`
}

type GrackleUpdateRequest_RunWaitGroupsGarbageCollectionRequest 

type GrackleUpdateRequest_RunWaitGroupsGarbageCollectionRequest struct {
	RunWaitGroupsGarbageCollectionRequest *RunWaitGroupsGarbageCollectionRequest `` /* 127-byte string literal not displayed */
}

type GrackleUpdateRequest_SemaphoresDeleteNamespaceRequest 

type GrackleUpdateRequest_SemaphoresDeleteNamespaceRequest struct {
	SemaphoresDeleteNamespaceRequest *SemaphoresDeleteNamespaceRequest `protobuf:"bytes,7,opt,name=semaphores_delete_namespace_request,json=semaphoresDeleteNamespaceRequest,proto3,oneof"`
}

type GrackleUpdateRequest_UpdateBarrierRequest 

type GrackleUpdateRequest_UpdateBarrierRequest struct {
	UpdateBarrierRequest *UpdateBarrierRequest `protobuf:"bytes,25,opt,name=update_barrier_request,json=updateBarrierRequest,proto3,oneof"`
}

type GrackleUpdateRequest_UpdateNamespaceRequest 

type GrackleUpdateRequest_UpdateNamespaceRequest struct {
	UpdateNamespaceRequest *UpdateNamespaceRequest `protobuf:"bytes,21,opt,name=update_namespace_request,json=updateNamespaceRequest,proto3,oneof"`
}

type GrackleUpdateRequest_UpdateSemaphoreRequest 

type GrackleUpdateRequest_UpdateSemaphoreRequest struct {
	UpdateSemaphoreRequest *UpdateSemaphoreRequest `protobuf:"bytes,2,opt,name=update_semaphore_request,json=updateSemaphoreRequest,proto3,oneof"`
}

type GrackleUpdateRequest_WaitAtBarrierRequest 

type GrackleUpdateRequest_WaitAtBarrierRequest struct {
	WaitAtBarrierRequest *WaitAtBarrierRequest `protobuf:"bytes,27,opt,name=wait_at_barrier_request,json=waitAtBarrierRequest,proto3,oneof"`
}

type GrackleUpdateRequest_WaitGroupsDeleteNamespaceRequest 

type GrackleUpdateRequest_WaitGroupsDeleteNamespaceRequest struct {
	WaitGroupsDeleteNamespaceRequest *WaitGroupsDeleteNamespaceRequest `protobuf:"bytes,13,opt,name=wait_groups_delete_namespace_request,json=waitGroupsDeleteNamespaceRequest,proto3,oneof"`
}

type GrackleUpdateResponse 

type GrackleUpdateResponse struct {

	// Types that are valid to be assigned to Response:
	//
	//	*GrackleUpdateResponse_CreateSemaphoreResponse
	//	*GrackleUpdateResponse_UpdateSemaphoreResponse
	//	*GrackleUpdateResponse_DeleteSemaphoreResponse
	//	*GrackleUpdateResponse_AcquireSemaphoreResponse
	//	*GrackleUpdateResponse_ReleaseSemaphoreResponse
	//	*GrackleUpdateResponse_RunSemaphoresGarbageCollectionResponse
	//	*GrackleUpdateResponse_SemaphoresDeleteNamespaceResponse
	//	*GrackleUpdateResponse_CreateWaitGroupResponse
	//	*GrackleUpdateResponse_DeleteWaitGroupResponse
	//	*GrackleUpdateResponse_AddJobsToWaitGroupResponse
	//	*GrackleUpdateResponse_CompleteJobsFromWaitGroupResponse
	//	*GrackleUpdateResponse_RunWaitGroupsGarbageCollectionResponse
	//	*GrackleUpdateResponse_WaitGroupsDeleteNamespaceResponse
	//	*GrackleUpdateResponse_AcquireLockResponse
	//	*GrackleUpdateResponse_ReleaseLockResponse
	//	*GrackleUpdateResponse_DeleteLockResponse
	//	*GrackleUpdateResponse_GetLockResponse
	//	*GrackleUpdateResponse_RunLocksGarbageCollectionResponse
	//	*GrackleUpdateResponse_LocksDeleteNamespaceResponse
	//	*GrackleUpdateResponse_CreateNamespaceResponse
	//	*GrackleUpdateResponse_UpdateNamespaceResponse
	//	*GrackleUpdateResponse_DeleteNamespaceResponse
	//	*GrackleUpdateResponse_CreateBarrierResponse
	//	*GrackleUpdateResponse_DeleteBarrierResponse
	//	*GrackleUpdateResponse_UpdateBarrierResponse
	//	*GrackleUpdateResponse_ArriveAtBarrierResponse
	//	*GrackleUpdateResponse_WaitAtBarrierResponse
	//	*GrackleUpdateResponse_RunBarriersGarbageCollectionResponse
	//	*GrackleUpdateResponse_BarriersDeleteNamespaceResponse
	Response isGrackleUpdateResponse_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

func (*GrackleUpdateResponse) Descriptor deprecated 

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

Deprecated: Use GrackleUpdateResponse.ProtoReflect.Descriptor instead.

func (*GrackleUpdateResponse) GetAcquireLockResponse 

func (x *GrackleUpdateResponse) GetAcquireLockResponse() *AcquireLockResponse

func (*GrackleUpdateResponse) GetAcquireSemaphoreResponse 

func (x *GrackleUpdateResponse) GetAcquireSemaphoreResponse() *AcquireSemaphoreResponse

func (*GrackleUpdateResponse) GetAddJobsToWaitGroupResponse 

func (x *GrackleUpdateResponse) GetAddJobsToWaitGroupResponse() *AddJobsToWaitGroupResponse

func (*GrackleUpdateResponse) GetArriveAtBarrierResponse 

func (x *GrackleUpdateResponse) GetArriveAtBarrierResponse() *ArriveAtBarrierResponse

func (*GrackleUpdateResponse) GetBarriersDeleteNamespaceResponse 

func (x *GrackleUpdateResponse) GetBarriersDeleteNamespaceResponse() *BarriersDeleteNamespaceResponse

func (*GrackleUpdateResponse) GetCompleteJobsFromWaitGroupResponse 

func (x *GrackleUpdateResponse) GetCompleteJobsFromWaitGroupResponse() *CompleteJobsFromWaitGroupResponse

func (*GrackleUpdateResponse) GetCreateBarrierResponse 

func (x *GrackleUpdateResponse) GetCreateBarrierResponse() *CreateBarrierResponse

func (*GrackleUpdateResponse) GetCreateNamespaceResponse 

func (x *GrackleUpdateResponse) GetCreateNamespaceResponse() *CreateNamespaceResponse

func (*GrackleUpdateResponse) GetCreateSemaphoreResponse 

func (x *GrackleUpdateResponse) GetCreateSemaphoreResponse() *CreateSemaphoreResponse

func (*GrackleUpdateResponse) GetCreateWaitGroupResponse 

func (x *GrackleUpdateResponse) GetCreateWaitGroupResponse() *CreateWaitGroupResponse

func (*GrackleUpdateResponse) GetDeleteBarrierResponse 

func (x *GrackleUpdateResponse) GetDeleteBarrierResponse() *DeleteBarrierResponse

func (*GrackleUpdateResponse) GetDeleteLockResponse 

func (x *GrackleUpdateResponse) GetDeleteLockResponse() *DeleteLockResponse

func (*GrackleUpdateResponse) GetDeleteNamespaceResponse 

func (x *GrackleUpdateResponse) GetDeleteNamespaceResponse() *DeleteNamespaceResponse

func (*GrackleUpdateResponse) GetDeleteSemaphoreResponse 

func (x *GrackleUpdateResponse) GetDeleteSemaphoreResponse() *DeleteSemaphoreResponse

func (*GrackleUpdateResponse) GetDeleteWaitGroupResponse 

func (x *GrackleUpdateResponse) GetDeleteWaitGroupResponse() *DeleteWaitGroupResponse

func (*GrackleUpdateResponse) GetGetLockResponse 

func (x *GrackleUpdateResponse) GetGetLockResponse() *GetLockResponse

func (*GrackleUpdateResponse) GetLocksDeleteNamespaceResponse 

func (x *GrackleUpdateResponse) GetLocksDeleteNamespaceResponse() *LocksDeleteNamespaceResponse

func (*GrackleUpdateResponse) GetReleaseLockResponse 

func (x *GrackleUpdateResponse) GetReleaseLockResponse() *ReleaseLockResponse

func (*GrackleUpdateResponse) GetReleaseSemaphoreResponse 

func (x *GrackleUpdateResponse) GetReleaseSemaphoreResponse() *ReleaseSemaphoreResponse

func (*GrackleUpdateResponse) GetResponse 

func (x *GrackleUpdateResponse) GetResponse() isGrackleUpdateResponse_Response

func (*GrackleUpdateResponse) GetRunBarriersGarbageCollectionResponse 

func (x *GrackleUpdateResponse) GetRunBarriersGarbageCollectionResponse() *RunBarriersGarbageCollectionResponse

func (*GrackleUpdateResponse) GetRunLocksGarbageCollectionResponse 

func (x *GrackleUpdateResponse) GetRunLocksGarbageCollectionResponse() *RunLocksGarbageCollectionResponse

func (*GrackleUpdateResponse) GetRunSemaphoresGarbageCollectionResponse 

func (x *GrackleUpdateResponse) GetRunSemaphoresGarbageCollectionResponse() *RunSemaphoresGarbageCollectionResponse

func (*GrackleUpdateResponse) GetRunWaitGroupsGarbageCollectionResponse 

func (x *GrackleUpdateResponse) GetRunWaitGroupsGarbageCollectionResponse() *RunWaitGroupsGarbageCollectionResponse

func (*GrackleUpdateResponse) GetSemaphoresDeleteNamespaceResponse 

func (x *GrackleUpdateResponse) GetSemaphoresDeleteNamespaceResponse() *SemaphoresDeleteNamespaceResponse

func (*GrackleUpdateResponse) GetUpdateBarrierResponse 

func (x *GrackleUpdateResponse) GetUpdateBarrierResponse() *UpdateBarrierResponse

func (*GrackleUpdateResponse) GetUpdateNamespaceResponse 

func (x *GrackleUpdateResponse) GetUpdateNamespaceResponse() *UpdateNamespaceResponse

func (*GrackleUpdateResponse) GetUpdateSemaphoreResponse 

func (x *GrackleUpdateResponse) GetUpdateSemaphoreResponse() *UpdateSemaphoreResponse

func (*GrackleUpdateResponse) GetWaitAtBarrierResponse 

func (x *GrackleUpdateResponse) GetWaitAtBarrierResponse() *WaitAtBarrierResponse

func (*GrackleUpdateResponse) GetWaitGroupsDeleteNamespaceResponse 

func (x *GrackleUpdateResponse) GetWaitGroupsDeleteNamespaceResponse() *WaitGroupsDeleteNamespaceResponse

func (*GrackleUpdateResponse) ProtoMessage 

func (*GrackleUpdateResponse) ProtoMessage()

func (*GrackleUpdateResponse) ProtoReflect 

func (x *GrackleUpdateResponse) ProtoReflect() protoreflect.Message

func (*GrackleUpdateResponse) Reset 

func (x *GrackleUpdateResponse) Reset()

func (*GrackleUpdateResponse) String 

func (x *GrackleUpdateResponse) String() string

type GrackleUpdateResponse_AcquireLockResponse 

type GrackleUpdateResponse_AcquireLockResponse struct {
	AcquireLockResponse *AcquireLockResponse `protobuf:"bytes,14,opt,name=acquire_lock_response,json=acquireLockResponse,proto3,oneof"`
}

type GrackleUpdateResponse_AcquireSemaphoreResponse 

type GrackleUpdateResponse_AcquireSemaphoreResponse struct {
	AcquireSemaphoreResponse *AcquireSemaphoreResponse `protobuf:"bytes,4,opt,name=acquire_semaphore_response,json=acquireSemaphoreResponse,proto3,oneof"`
}

type GrackleUpdateResponse_AddJobsToWaitGroupResponse 

type GrackleUpdateResponse_AddJobsToWaitGroupResponse struct {
	AddJobsToWaitGroupResponse *AddJobsToWaitGroupResponse `protobuf:"bytes,10,opt,name=add_jobs_to_wait_group_response,json=addJobsToWaitGroupResponse,proto3,oneof"`
}

type GrackleUpdateResponse_ArriveAtBarrierResponse 

type GrackleUpdateResponse_ArriveAtBarrierResponse struct {
	ArriveAtBarrierResponse *ArriveAtBarrierResponse `protobuf:"bytes,26,opt,name=arrive_at_barrier_response,json=arriveAtBarrierResponse,proto3,oneof"`
}

type GrackleUpdateResponse_BarriersDeleteNamespaceResponse 

type GrackleUpdateResponse_BarriersDeleteNamespaceResponse struct {
	BarriersDeleteNamespaceResponse *BarriersDeleteNamespaceResponse `protobuf:"bytes,29,opt,name=barriers_delete_namespace_response,json=barriersDeleteNamespaceResponse,proto3,oneof"`
}

type GrackleUpdateResponse_CompleteJobsFromWaitGroupResponse 

type GrackleUpdateResponse_CompleteJobsFromWaitGroupResponse struct {
	CompleteJobsFromWaitGroupResponse *CompleteJobsFromWaitGroupResponse `protobuf:"bytes,11,opt,name=complete_jobs_from_wait_group_response,json=completeJobsFromWaitGroupResponse,proto3,oneof"`
}

type GrackleUpdateResponse_CreateBarrierResponse 

type GrackleUpdateResponse_CreateBarrierResponse struct {
	CreateBarrierResponse *CreateBarrierResponse `protobuf:"bytes,23,opt,name=create_barrier_response,json=createBarrierResponse,proto3,oneof"`
}

type GrackleUpdateResponse_CreateNamespaceResponse 

type GrackleUpdateResponse_CreateNamespaceResponse struct {
	CreateNamespaceResponse *CreateNamespaceResponse `protobuf:"bytes,20,opt,name=create_namespace_response,json=createNamespaceResponse,proto3,oneof"`
}

type GrackleUpdateResponse_CreateSemaphoreResponse 

type GrackleUpdateResponse_CreateSemaphoreResponse struct {
	CreateSemaphoreResponse *CreateSemaphoreResponse `protobuf:"bytes,1,opt,name=create_semaphore_response,json=createSemaphoreResponse,proto3,oneof"`
}

type GrackleUpdateResponse_CreateWaitGroupResponse 

type GrackleUpdateResponse_CreateWaitGroupResponse struct {
	CreateWaitGroupResponse *CreateWaitGroupResponse `protobuf:"bytes,8,opt,name=create_wait_group_response,json=createWaitGroupResponse,proto3,oneof"`
}

type GrackleUpdateResponse_DeleteBarrierResponse 

type GrackleUpdateResponse_DeleteBarrierResponse struct {
	DeleteBarrierResponse *DeleteBarrierResponse `protobuf:"bytes,24,opt,name=delete_barrier_response,json=deleteBarrierResponse,proto3,oneof"`
}

type GrackleUpdateResponse_DeleteLockResponse 

type GrackleUpdateResponse_DeleteLockResponse struct {
	DeleteLockResponse *DeleteLockResponse `protobuf:"bytes,16,opt,name=delete_lock_response,json=deleteLockResponse,proto3,oneof"`
}

type GrackleUpdateResponse_DeleteNamespaceResponse 

type GrackleUpdateResponse_DeleteNamespaceResponse struct {
	DeleteNamespaceResponse *DeleteNamespaceResponse `protobuf:"bytes,22,opt,name=delete_namespace_response,json=deleteNamespaceResponse,proto3,oneof"`
}

type GrackleUpdateResponse_DeleteSemaphoreResponse 

type GrackleUpdateResponse_DeleteSemaphoreResponse struct {
	DeleteSemaphoreResponse *DeleteSemaphoreResponse `protobuf:"bytes,3,opt,name=delete_semaphore_response,json=deleteSemaphoreResponse,proto3,oneof"`
}

type GrackleUpdateResponse_DeleteWaitGroupResponse 

type GrackleUpdateResponse_DeleteWaitGroupResponse struct {
	DeleteWaitGroupResponse *DeleteWaitGroupResponse `protobuf:"bytes,9,opt,name=delete_wait_group_response,json=deleteWaitGroupResponse,proto3,oneof"`
}

type GrackleUpdateResponse_GetLockResponse 

type GrackleUpdateResponse_GetLockResponse struct {
	GetLockResponse *GetLockResponse `protobuf:"bytes,17,opt,name=get_lock_response,json=getLockResponse,proto3,oneof"`
}

type GrackleUpdateResponse_LocksDeleteNamespaceResponse 

type GrackleUpdateResponse_LocksDeleteNamespaceResponse struct {
	LocksDeleteNamespaceResponse *LocksDeleteNamespaceResponse `protobuf:"bytes,19,opt,name=locks_delete_namespace_response,json=locksDeleteNamespaceResponse,proto3,oneof"`
}

type GrackleUpdateResponse_ReleaseLockResponse 

type GrackleUpdateResponse_ReleaseLockResponse struct {
	ReleaseLockResponse *ReleaseLockResponse `protobuf:"bytes,15,opt,name=release_lock_response,json=releaseLockResponse,proto3,oneof"`
}

type GrackleUpdateResponse_ReleaseSemaphoreResponse 

type GrackleUpdateResponse_ReleaseSemaphoreResponse struct {
	ReleaseSemaphoreResponse *ReleaseSemaphoreResponse `protobuf:"bytes,5,opt,name=release_semaphore_response,json=releaseSemaphoreResponse,proto3,oneof"`
}

type GrackleUpdateResponse_RunBarriersGarbageCollectionResponse 

type GrackleUpdateResponse_RunBarriersGarbageCollectionResponse struct {
	RunBarriersGarbageCollectionResponse *RunBarriersGarbageCollectionResponse `protobuf:"bytes,28,opt,name=run_barriers_garbage_collection_response,json=runBarriersGarbageCollectionResponse,proto3,oneof"`
}

type GrackleUpdateResponse_RunLocksGarbageCollectionResponse 

type GrackleUpdateResponse_RunLocksGarbageCollectionResponse struct {
	RunLocksGarbageCollectionResponse *RunLocksGarbageCollectionResponse `protobuf:"bytes,18,opt,name=run_locks_garbage_collection_response,json=runLocksGarbageCollectionResponse,proto3,oneof"`
}

type GrackleUpdateResponse_RunSemaphoresGarbageCollectionResponse 

type GrackleUpdateResponse_RunSemaphoresGarbageCollectionResponse struct {
	RunSemaphoresGarbageCollectionResponse *RunSemaphoresGarbageCollectionResponse `` /* 127-byte string literal not displayed */
}

type GrackleUpdateResponse_RunWaitGroupsGarbageCollectionResponse 

type GrackleUpdateResponse_RunWaitGroupsGarbageCollectionResponse struct {
	RunWaitGroupsGarbageCollectionResponse *RunWaitGroupsGarbageCollectionResponse `` /* 129-byte string literal not displayed */
}

type GrackleUpdateResponse_SemaphoresDeleteNamespaceResponse 

type GrackleUpdateResponse_SemaphoresDeleteNamespaceResponse struct {
	SemaphoresDeleteNamespaceResponse *SemaphoresDeleteNamespaceResponse `protobuf:"bytes,7,opt,name=semaphores_delete_namespace_response,json=semaphoresDeleteNamespaceResponse,proto3,oneof"`
}

type GrackleUpdateResponse_UpdateBarrierResponse 

type GrackleUpdateResponse_UpdateBarrierResponse struct {
	UpdateBarrierResponse *UpdateBarrierResponse `protobuf:"bytes,25,opt,name=update_barrier_response,json=updateBarrierResponse,proto3,oneof"`
}

type GrackleUpdateResponse_UpdateNamespaceResponse 

type GrackleUpdateResponse_UpdateNamespaceResponse struct {
	UpdateNamespaceResponse *UpdateNamespaceResponse `protobuf:"bytes,21,opt,name=update_namespace_response,json=updateNamespaceResponse,proto3,oneof"`
}

type GrackleUpdateResponse_UpdateSemaphoreResponse 

type GrackleUpdateResponse_UpdateSemaphoreResponse struct {
	UpdateSemaphoreResponse *UpdateSemaphoreResponse `protobuf:"bytes,2,opt,name=update_semaphore_response,json=updateSemaphoreResponse,proto3,oneof"`
}

type GrackleUpdateResponse_WaitAtBarrierResponse 

type GrackleUpdateResponse_WaitAtBarrierResponse struct {
	WaitAtBarrierResponse *WaitAtBarrierResponse `protobuf:"bytes,27,opt,name=wait_at_barrier_response,json=waitAtBarrierResponse,proto3,oneof"`
}

type GrackleUpdateResponse_WaitGroupsDeleteNamespaceResponse 

type GrackleUpdateResponse_WaitGroupsDeleteNamespaceResponse struct {
	WaitGroupsDeleteNamespaceResponse *WaitGroupsDeleteNamespaceResponse `protobuf:"bytes,13,opt,name=wait_groups_delete_namespace_response,json=waitGroupsDeleteNamespaceResponse,proto3,oneof"`
}

type ListBarrierParticipantsRequest 

type ListBarrierParticipantsRequest struct {
	NamespaceId     *NamespaceId     `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	BarrierName     string           `protobuf:"bytes,2,opt,name=barrier_name,json=barrierName,proto3" json:"barrier_name,omitempty"`
	Generation      uint64           `protobuf:"varint,3,opt,name=generation,proto3" json:"generation,omitempty"`
	PaginationToken *PaginationToken `protobuf:"bytes,4,opt,name=pagination_token,json=paginationToken,proto3" json:"pagination_token,omitempty"`
	Limit           int32            `protobuf:"varint,5,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*ListBarrierParticipantsRequest) Descriptor deprecated 

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

Deprecated: Use ListBarrierParticipantsRequest.ProtoReflect.Descriptor instead.

func (*ListBarrierParticipantsRequest) GetBarrierName 

func (x *ListBarrierParticipantsRequest) GetBarrierName() string

func (*ListBarrierParticipantsRequest) GetGeneration 

func (x *ListBarrierParticipantsRequest) GetGeneration() uint64

func (*ListBarrierParticipantsRequest) GetLimit 

func (x *ListBarrierParticipantsRequest) GetLimit() int32

func (*ListBarrierParticipantsRequest) GetNamespaceId 

func (x *ListBarrierParticipantsRequest) GetNamespaceId() *NamespaceId

func (*ListBarrierParticipantsRequest) GetPaginationToken 

func (x *ListBarrierParticipantsRequest) GetPaginationToken() *PaginationToken

func (*ListBarrierParticipantsRequest) ProtoMessage 

func (*ListBarrierParticipantsRequest) ProtoMessage()

func (*ListBarrierParticipantsRequest) ProtoReflect 

func (x *ListBarrierParticipantsRequest) ProtoReflect() protoreflect.Message

func (*ListBarrierParticipantsRequest) Reset 

func (x *ListBarrierParticipantsRequest) Reset()

func (*ListBarrierParticipantsRequest) String 

func (x *ListBarrierParticipantsRequest) String() string

type ListBarrierParticipantsResponse 

type ListBarrierParticipantsResponse struct {
	Participants            []*BarrierParticipant `protobuf:"bytes,1,rep,name=participants,proto3" json:"participants,omitempty"`
	NextPaginationToken     *PaginationToken      `protobuf:"bytes,2,opt,name=next_pagination_token,json=nextPaginationToken,proto3" json:"next_pagination_token,omitempty"`
	PreviousPaginationToken *PaginationToken      `` /* 132-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ListBarrierParticipantsResponse) Descriptor deprecated 

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

Deprecated: Use ListBarrierParticipantsResponse.ProtoReflect.Descriptor instead.

func (*ListBarrierParticipantsResponse) GetNextPaginationToken 

func (x *ListBarrierParticipantsResponse) GetNextPaginationToken() *PaginationToken

func (*ListBarrierParticipantsResponse) GetParticipants 

func (x *ListBarrierParticipantsResponse) GetParticipants() []*BarrierParticipant

func (*ListBarrierParticipantsResponse) GetPreviousPaginationToken 

func (x *ListBarrierParticipantsResponse) GetPreviousPaginationToken() *PaginationToken

func (*ListBarrierParticipantsResponse) ProtoMessage 

func (*ListBarrierParticipantsResponse) ProtoMessage()

func (*ListBarrierParticipantsResponse) ProtoReflect 

func (x *ListBarrierParticipantsResponse) ProtoReflect() protoreflect.Message

func (*ListBarrierParticipantsResponse) Reset 

func (x *ListBarrierParticipantsResponse) Reset()

func (*ListBarrierParticipantsResponse) String 

func (x *ListBarrierParticipantsResponse) String() string

type ListBarriersRequest 

type ListBarriersRequest struct {
	NamespaceId     *NamespaceId     `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	Now             int64            `protobuf:"varint,2,opt,name=now,proto3" json:"now,omitempty"`
	PaginationToken *PaginationToken `protobuf:"bytes,3,opt,name=pagination_token,json=paginationToken,proto3" json:"pagination_token,omitempty"`
	Limit           int32            `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*ListBarriersRequest) Descriptor deprecated 

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

Deprecated: Use ListBarriersRequest.ProtoReflect.Descriptor instead.

func (*ListBarriersRequest) GetLimit 

func (x *ListBarriersRequest) GetLimit() int32

func (*ListBarriersRequest) GetNamespaceId 

func (x *ListBarriersRequest) GetNamespaceId() *NamespaceId

func (*ListBarriersRequest) GetNow 

func (x *ListBarriersRequest) GetNow() int64

func (*ListBarriersRequest) GetPaginationToken 

func (x *ListBarriersRequest) GetPaginationToken() *PaginationToken

func (*ListBarriersRequest) ProtoMessage 

func (*ListBarriersRequest) ProtoMessage()

func (*ListBarriersRequest) ProtoReflect 

func (x *ListBarriersRequest) ProtoReflect() protoreflect.Message

func (*ListBarriersRequest) Reset 

func (x *ListBarriersRequest) Reset()

func (*ListBarriersRequest) String 

func (x *ListBarriersRequest) String() string

type ListBarriersResponse 

type ListBarriersResponse struct {
	Barriers                []*Barrier       `protobuf:"bytes,1,rep,name=barriers,proto3" json:"barriers,omitempty"`
	NextPaginationToken     *PaginationToken `protobuf:"bytes,2,opt,name=next_pagination_token,json=nextPaginationToken,proto3" json:"next_pagination_token,omitempty"`
	PreviousPaginationToken *PaginationToken `` /* 132-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ListBarriersResponse) Descriptor deprecated 

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

Deprecated: Use ListBarriersResponse.ProtoReflect.Descriptor instead.

func (*ListBarriersResponse) GetBarriers 

func (x *ListBarriersResponse) GetBarriers() []*Barrier

func (*ListBarriersResponse) GetNextPaginationToken 

func (x *ListBarriersResponse) GetNextPaginationToken() *PaginationToken

func (*ListBarriersResponse) GetPreviousPaginationToken 

func (x *ListBarriersResponse) GetPreviousPaginationToken() *PaginationToken

func (*ListBarriersResponse) ProtoMessage 

func (*ListBarriersResponse) ProtoMessage()

func (*ListBarriersResponse) ProtoReflect 

func (x *ListBarriersResponse) ProtoReflect() protoreflect.Message

func (*ListBarriersResponse) Reset 

func (x *ListBarriersResponse) Reset()

func (*ListBarriersResponse) String 

func (x *ListBarriersResponse) String() string

type ListLocksRequest 

type ListLocksRequest struct {
	NamespaceId     *NamespaceId     `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	Now             int64            `protobuf:"varint,2,opt,name=now,proto3" json:"now,omitempty"`
	PaginationToken *PaginationToken `protobuf:"bytes,3,opt,name=pagination_token,json=paginationToken,proto3" json:"pagination_token,omitempty"`
	Limit           int32            `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*ListLocksRequest) Descriptor deprecated 

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

Deprecated: Use ListLocksRequest.ProtoReflect.Descriptor instead.

func (*ListLocksRequest) GetLimit 

func (x *ListLocksRequest) GetLimit() int32

func (*ListLocksRequest) GetNamespaceId 

func (x *ListLocksRequest) GetNamespaceId() *NamespaceId

func (*ListLocksRequest) GetNow 

func (x *ListLocksRequest) GetNow() int64

func (*ListLocksRequest) GetPaginationToken 

func (x *ListLocksRequest) GetPaginationToken() *PaginationToken

func (*ListLocksRequest) ProtoMessage 

func (*ListLocksRequest) ProtoMessage()

func (*ListLocksRequest) ProtoReflect 

func (x *ListLocksRequest) ProtoReflect() protoreflect.Message

func (*ListLocksRequest) Reset 

func (x *ListLocksRequest) Reset()

func (*ListLocksRequest) String 

func (x *ListLocksRequest) String() string

type ListLocksResponse 

type ListLocksResponse struct {
	Locks                   []*Lock          `protobuf:"bytes,1,rep,name=locks,proto3" json:"locks,omitempty"`
	NextPaginationToken     *PaginationToken `protobuf:"bytes,2,opt,name=next_pagination_token,json=nextPaginationToken,proto3" json:"next_pagination_token,omitempty"`
	PreviousPaginationToken *PaginationToken `` /* 132-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ListLocksResponse) Descriptor deprecated 

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

Deprecated: Use ListLocksResponse.ProtoReflect.Descriptor instead.

func (*ListLocksResponse) GetLocks 

func (x *ListLocksResponse) GetLocks() []*Lock

func (*ListLocksResponse) GetNextPaginationToken 

func (x *ListLocksResponse) GetNextPaginationToken() *PaginationToken

func (*ListLocksResponse) GetPreviousPaginationToken 

func (x *ListLocksResponse) GetPreviousPaginationToken() *PaginationToken

func (*ListLocksResponse) ProtoMessage 

func (*ListLocksResponse) ProtoMessage()

func (*ListLocksResponse) ProtoReflect 

func (x *ListLocksResponse) ProtoReflect() protoreflect.Message

func (*ListLocksResponse) Reset 

func (x *ListLocksResponse) Reset()

func (*ListLocksResponse) String 

func (x *ListLocksResponse) String() string

type ListNamespacesRequest 

type ListNamespacesRequest struct {
	AccountId       uint64           `protobuf:"varint,1,opt,name=account_id,json=accountId,proto3" json:"account_id,omitempty"`
	PaginationToken *PaginationToken `protobuf:"bytes,2,opt,name=pagination_token,json=paginationToken,proto3" json:"pagination_token,omitempty"`
	Limit           int32            `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*ListNamespacesRequest) Descriptor deprecated 

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

Deprecated: Use ListNamespacesRequest.ProtoReflect.Descriptor instead.

func (*ListNamespacesRequest) GetAccountId 

func (x *ListNamespacesRequest) GetAccountId() uint64

func (*ListNamespacesRequest) GetLimit 

func (x *ListNamespacesRequest) GetLimit() int32

func (*ListNamespacesRequest) GetPaginationToken 

func (x *ListNamespacesRequest) GetPaginationToken() *PaginationToken

func (*ListNamespacesRequest) ProtoMessage 

func (*ListNamespacesRequest) ProtoMessage()

func (*ListNamespacesRequest) ProtoReflect 

func (x *ListNamespacesRequest) ProtoReflect() protoreflect.Message

func (*ListNamespacesRequest) Reset 

func (x *ListNamespacesRequest) Reset()

func (*ListNamespacesRequest) String 

func (x *ListNamespacesRequest) String() string

type ListNamespacesResponse 

type ListNamespacesResponse struct {
	Namespaces              []*Namespace     `protobuf:"bytes,1,rep,name=namespaces,proto3" json:"namespaces,omitempty"`
	NextPaginationToken     *PaginationToken `protobuf:"bytes,2,opt,name=next_pagination_token,json=nextPaginationToken,proto3" json:"next_pagination_token,omitempty"`
	PreviousPaginationToken *PaginationToken `` /* 132-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ListNamespacesResponse) Descriptor deprecated 

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

Deprecated: Use ListNamespacesResponse.ProtoReflect.Descriptor instead.

func (*ListNamespacesResponse) GetNamespaces 

func (x *ListNamespacesResponse) GetNamespaces() []*Namespace

func (*ListNamespacesResponse) GetNextPaginationToken 

func (x *ListNamespacesResponse) GetNextPaginationToken() *PaginationToken

func (*ListNamespacesResponse) GetPreviousPaginationToken 

func (x *ListNamespacesResponse) GetPreviousPaginationToken() *PaginationToken

func (*ListNamespacesResponse) ProtoMessage 

func (*ListNamespacesResponse) ProtoMessage()

func (*ListNamespacesResponse) ProtoReflect 

func (x *ListNamespacesResponse) ProtoReflect() protoreflect.Message

func (*ListNamespacesResponse) Reset 

func (x *ListNamespacesResponse) Reset()

func (*ListNamespacesResponse) String 

func (x *ListNamespacesResponse) String() string

type ListSemaphoreHoldersRequest 

type ListSemaphoreHoldersRequest struct {
	NamespaceId     *NamespaceId     `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	SemaphoreName   string           `protobuf:"bytes,2,opt,name=semaphore_name,json=semaphoreName,proto3" json:"semaphore_name,omitempty"`
	PaginationToken *PaginationToken `protobuf:"bytes,3,opt,name=pagination_token,json=paginationToken,proto3" json:"pagination_token,omitempty"`
	Limit           int32            `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*ListSemaphoreHoldersRequest) Descriptor deprecated 

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

Deprecated: Use ListSemaphoreHoldersRequest.ProtoReflect.Descriptor instead.

func (*ListSemaphoreHoldersRequest) GetLimit 

func (x *ListSemaphoreHoldersRequest) GetLimit() int32

func (*ListSemaphoreHoldersRequest) GetNamespaceId 

func (x *ListSemaphoreHoldersRequest) GetNamespaceId() *NamespaceId

func (*ListSemaphoreHoldersRequest) GetPaginationToken 

func (x *ListSemaphoreHoldersRequest) GetPaginationToken() *PaginationToken

func (*ListSemaphoreHoldersRequest) GetSemaphoreName 

func (x *ListSemaphoreHoldersRequest) GetSemaphoreName() string

func (*ListSemaphoreHoldersRequest) ProtoMessage 

func (*ListSemaphoreHoldersRequest) ProtoMessage()

func (*ListSemaphoreHoldersRequest) ProtoReflect 

func (x *ListSemaphoreHoldersRequest) ProtoReflect() protoreflect.Message

func (*ListSemaphoreHoldersRequest) Reset 

func (x *ListSemaphoreHoldersRequest) Reset()

func (*ListSemaphoreHoldersRequest) String 

func (x *ListSemaphoreHoldersRequest) String() string

type ListSemaphoreHoldersResponse 

type ListSemaphoreHoldersResponse struct {
	Holders                 []*SemaphoreHolder `protobuf:"bytes,1,rep,name=holders,proto3" json:"holders,omitempty"`
	NextPaginationToken     *PaginationToken   `protobuf:"bytes,2,opt,name=next_pagination_token,json=nextPaginationToken,proto3" json:"next_pagination_token,omitempty"`
	PreviousPaginationToken *PaginationToken   `` /* 132-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ListSemaphoreHoldersResponse) Descriptor deprecated 

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

Deprecated: Use ListSemaphoreHoldersResponse.ProtoReflect.Descriptor instead.

func (*ListSemaphoreHoldersResponse) GetHolders 

func (x *ListSemaphoreHoldersResponse) GetHolders() []*SemaphoreHolder

func (*ListSemaphoreHoldersResponse) GetNextPaginationToken 

func (x *ListSemaphoreHoldersResponse) GetNextPaginationToken() *PaginationToken

func (*ListSemaphoreHoldersResponse) GetPreviousPaginationToken 

func (x *ListSemaphoreHoldersResponse) GetPreviousPaginationToken() *PaginationToken

func (*ListSemaphoreHoldersResponse) ProtoMessage 

func (*ListSemaphoreHoldersResponse) ProtoMessage()

func (*ListSemaphoreHoldersResponse) ProtoReflect 

func (x *ListSemaphoreHoldersResponse) ProtoReflect() protoreflect.Message

func (*ListSemaphoreHoldersResponse) Reset 

func (x *ListSemaphoreHoldersResponse) Reset()

func (*ListSemaphoreHoldersResponse) String 

func (x *ListSemaphoreHoldersResponse) String() string

type ListSemaphoresRequest 

type ListSemaphoresRequest struct {
	NamespaceId     *NamespaceId     `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	PaginationToken *PaginationToken `protobuf:"bytes,2,opt,name=pagination_token,json=paginationToken,proto3" json:"pagination_token,omitempty"`
	Limit           int32            `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*ListSemaphoresRequest) Descriptor deprecated 

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

Deprecated: Use ListSemaphoresRequest.ProtoReflect.Descriptor instead.

func (*ListSemaphoresRequest) GetLimit 

func (x *ListSemaphoresRequest) GetLimit() int32

func (*ListSemaphoresRequest) GetNamespaceId 

func (x *ListSemaphoresRequest) GetNamespaceId() *NamespaceId

func (*ListSemaphoresRequest) GetPaginationToken 

func (x *ListSemaphoresRequest) GetPaginationToken() *PaginationToken

func (*ListSemaphoresRequest) ProtoMessage 

func (*ListSemaphoresRequest) ProtoMessage()

func (*ListSemaphoresRequest) ProtoReflect 

func (x *ListSemaphoresRequest) ProtoReflect() protoreflect.Message

func (*ListSemaphoresRequest) Reset 

func (x *ListSemaphoresRequest) Reset()

func (*ListSemaphoresRequest) String 

func (x *ListSemaphoresRequest) String() string

type ListSemaphoresResponse 

type ListSemaphoresResponse struct {
	Semaphores              []*Semaphore     `protobuf:"bytes,1,rep,name=semaphores,proto3" json:"semaphores,omitempty"`
	NextPaginationToken     *PaginationToken `protobuf:"bytes,2,opt,name=next_pagination_token,json=nextPaginationToken,proto3" json:"next_pagination_token,omitempty"`
	PreviousPaginationToken *PaginationToken `` /* 132-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ListSemaphoresResponse) Descriptor deprecated 

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

Deprecated: Use ListSemaphoresResponse.ProtoReflect.Descriptor instead.

func (*ListSemaphoresResponse) GetNextPaginationToken 

func (x *ListSemaphoresResponse) GetNextPaginationToken() *PaginationToken

func (*ListSemaphoresResponse) GetPreviousPaginationToken 

func (x *ListSemaphoresResponse) GetPreviousPaginationToken() *PaginationToken

func (*ListSemaphoresResponse) GetSemaphores 

func (x *ListSemaphoresResponse) GetSemaphores() []*Semaphore

func (*ListSemaphoresResponse) ProtoMessage 

func (*ListSemaphoresResponse) ProtoMessage()

func (*ListSemaphoresResponse) ProtoReflect 

func (x *ListSemaphoresResponse) ProtoReflect() protoreflect.Message

func (*ListSemaphoresResponse) Reset 

func (x *ListSemaphoresResponse) Reset()

func (*ListSemaphoresResponse) String 

func (x *ListSemaphoresResponse) String() string

type ListWaitGroupJobsRequest 

type ListWaitGroupJobsRequest struct {
	NamespaceId     *NamespaceId     `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	WaitGroupName   string           `protobuf:"bytes,2,opt,name=wait_group_name,json=waitGroupName,proto3" json:"wait_group_name,omitempty"`
	PaginationToken *PaginationToken `protobuf:"bytes,3,opt,name=pagination_token,json=paginationToken,proto3" json:"pagination_token,omitempty"`
	Limit           int32            `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*ListWaitGroupJobsRequest) Descriptor deprecated 

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

Deprecated: Use ListWaitGroupJobsRequest.ProtoReflect.Descriptor instead.

func (*ListWaitGroupJobsRequest) GetLimit 

func (x *ListWaitGroupJobsRequest) GetLimit() int32

func (*ListWaitGroupJobsRequest) GetNamespaceId 

func (x *ListWaitGroupJobsRequest) GetNamespaceId() *NamespaceId

func (*ListWaitGroupJobsRequest) GetPaginationToken 

func (x *ListWaitGroupJobsRequest) GetPaginationToken() *PaginationToken

func (*ListWaitGroupJobsRequest) GetWaitGroupName 

func (x *ListWaitGroupJobsRequest) GetWaitGroupName() string

func (*ListWaitGroupJobsRequest) ProtoMessage 

func (*ListWaitGroupJobsRequest) ProtoMessage()

func (*ListWaitGroupJobsRequest) ProtoReflect 

func (x *ListWaitGroupJobsRequest) ProtoReflect() protoreflect.Message

func (*ListWaitGroupJobsRequest) Reset 

func (x *ListWaitGroupJobsRequest) Reset()

func (*ListWaitGroupJobsRequest) String 

func (x *ListWaitGroupJobsRequest) String() string

type ListWaitGroupJobsResponse 

type ListWaitGroupJobsResponse struct {
	Jobs                    []*WaitGroupJob  `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"`
	NextPaginationToken     *PaginationToken `protobuf:"bytes,2,opt,name=next_pagination_token,json=nextPaginationToken,proto3" json:"next_pagination_token,omitempty"`
	PreviousPaginationToken *PaginationToken `` /* 132-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ListWaitGroupJobsResponse) Descriptor deprecated 

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

Deprecated: Use ListWaitGroupJobsResponse.ProtoReflect.Descriptor instead.

func (*ListWaitGroupJobsResponse) GetJobs 

func (x *ListWaitGroupJobsResponse) GetJobs() []*WaitGroupJob

func (*ListWaitGroupJobsResponse) GetNextPaginationToken 

func (x *ListWaitGroupJobsResponse) GetNextPaginationToken() *PaginationToken

func (*ListWaitGroupJobsResponse) GetPreviousPaginationToken 

func (x *ListWaitGroupJobsResponse) GetPreviousPaginationToken() *PaginationToken

func (*ListWaitGroupJobsResponse) ProtoMessage 

func (*ListWaitGroupJobsResponse) ProtoMessage()

func (*ListWaitGroupJobsResponse) ProtoReflect 

func (x *ListWaitGroupJobsResponse) ProtoReflect() protoreflect.Message

func (*ListWaitGroupJobsResponse) Reset 

func (x *ListWaitGroupJobsResponse) Reset()

func (*ListWaitGroupJobsResponse) String 

func (x *ListWaitGroupJobsResponse) String() string

type ListWaitGroupsRequest 

type ListWaitGroupsRequest struct {
	NamespaceId     *NamespaceId     `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	PaginationToken *PaginationToken `protobuf:"bytes,2,opt,name=pagination_token,json=paginationToken,proto3" json:"pagination_token,omitempty"`
	Limit           int32            `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*ListWaitGroupsRequest) Descriptor deprecated 

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

Deprecated: Use ListWaitGroupsRequest.ProtoReflect.Descriptor instead.

func (*ListWaitGroupsRequest) GetLimit 

func (x *ListWaitGroupsRequest) GetLimit() int32

func (*ListWaitGroupsRequest) GetNamespaceId 

func (x *ListWaitGroupsRequest) GetNamespaceId() *NamespaceId

func (*ListWaitGroupsRequest) GetPaginationToken 

func (x *ListWaitGroupsRequest) GetPaginationToken() *PaginationToken

func (*ListWaitGroupsRequest) ProtoMessage 

func (*ListWaitGroupsRequest) ProtoMessage()

func (*ListWaitGroupsRequest) ProtoReflect 

func (x *ListWaitGroupsRequest) ProtoReflect() protoreflect.Message

func (*ListWaitGroupsRequest) Reset 

func (x *ListWaitGroupsRequest) Reset()

func (*ListWaitGroupsRequest) String 

func (x *ListWaitGroupsRequest) String() string

type ListWaitGroupsResponse 

type ListWaitGroupsResponse struct {
	WaitGroups              []*WaitGroup     `protobuf:"bytes,1,rep,name=wait_groups,json=waitGroups,proto3" json:"wait_groups,omitempty"`
	NextPaginationToken     *PaginationToken `protobuf:"bytes,2,opt,name=next_pagination_token,json=nextPaginationToken,proto3" json:"next_pagination_token,omitempty"`
	PreviousPaginationToken *PaginationToken `` /* 132-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ListWaitGroupsResponse) Descriptor deprecated 

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

Deprecated: Use ListWaitGroupsResponse.ProtoReflect.Descriptor instead.

func (*ListWaitGroupsResponse) GetNextPaginationToken 

func (x *ListWaitGroupsResponse) GetNextPaginationToken() *PaginationToken

func (*ListWaitGroupsResponse) GetPreviousPaginationToken 

func (x *ListWaitGroupsResponse) GetPreviousPaginationToken() *PaginationToken

func (*ListWaitGroupsResponse) GetWaitGroups 

func (x *ListWaitGroupsResponse) GetWaitGroups() []*WaitGroup

func (*ListWaitGroupsResponse) ProtoMessage 

func (*ListWaitGroupsResponse) ProtoMessage()

func (*ListWaitGroupsResponse) ProtoReflect 

func (x *ListWaitGroupsResponse) ProtoReflect() protoreflect.Message

func (*ListWaitGroupsResponse) Reset 

func (x *ListWaitGroupsResponse) Reset()

func (*ListWaitGroupsResponse) String 

func (x *ListWaitGroupsResponse) String() string

type Lock 

type Lock struct {
	Id          *LockId       `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	State       LockState     `protobuf:"varint,2,opt,name=state,proto3,enum=com.evrblk.grackle.corepb.LockState" json:"state,omitempty"`
	LockedAt    int64         `protobuf:"varint,3,opt,name=locked_at,json=lockedAt,proto3" json:"locked_at,omitempty"`
	LockHolders []*LockHolder `protobuf:"bytes,4,rep,name=lock_holders,json=lockHolders,proto3" json:"lock_holders,omitempty"`
	// contains filtered or unexported fields
}

func (*Lock) Descriptor deprecated 

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

Deprecated: Use Lock.ProtoReflect.Descriptor instead.

func (*Lock) GetId 

func (x *Lock) GetId() *LockId

func (*Lock) GetLockHolders 

func (x *Lock) GetLockHolders() []*LockHolder

func (*Lock) GetLockedAt 

func (x *Lock) GetLockedAt() int64

func (*Lock) GetState 

func (x *Lock) GetState() LockState

func (*Lock) MarshalBinary 

func (m *Lock) MarshalBinary() (data []byte, err error)

func (*Lock) ProtoMessage 

func (*Lock) ProtoMessage()

func (*Lock) ProtoReflect 

func (x *Lock) ProtoReflect() protoreflect.Message

func (*Lock) Reset 

func (x *Lock) Reset()

func (*Lock) String 

func (x *Lock) String() string

func (*Lock) UnmarshalBinary 

func (m *Lock) UnmarshalBinary(data []byte) error

type LockAncestor 

type LockAncestor struct {
	Id             *LockId `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	ExclusiveCount int64   `protobuf:"varint,2,opt,name=exclusive_count,json=exclusiveCount,proto3" json:"exclusive_count,omitempty"`
	SharedCount    int64   `protobuf:"varint,3,opt,name=shared_count,json=sharedCount,proto3" json:"shared_count,omitempty"`
	// contains filtered or unexported fields
}

func (*LockAncestor) Descriptor deprecated 

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

Deprecated: Use LockAncestor.ProtoReflect.Descriptor instead.

func (*LockAncestor) GetExclusiveCount 

func (x *LockAncestor) GetExclusiveCount() int64

func (*LockAncestor) GetId 

func (x *LockAncestor) GetId() *LockId

func (*LockAncestor) GetSharedCount 

func (x *LockAncestor) GetSharedCount() int64

func (*LockAncestor) MarshalBinary 

func (m *LockAncestor) MarshalBinary() (data []byte, err error)

func (*LockAncestor) ProtoMessage 

func (*LockAncestor) ProtoMessage()

func (*LockAncestor) ProtoReflect 

func (x *LockAncestor) ProtoReflect() protoreflect.Message

func (*LockAncestor) Reset 

func (x *LockAncestor) Reset()

func (*LockAncestor) String 

func (x *LockAncestor) String() string

func (*LockAncestor) UnmarshalBinary 

func (m *LockAncestor) UnmarshalBinary(data []byte) error

type LockHolder 

type LockHolder struct {
	ProcessId string `protobuf:"bytes,1,opt,name=process_id,json=processId,proto3" json:"process_id,omitempty"`
	LockedAt  int64  `protobuf:"varint,2,opt,name=locked_at,json=lockedAt,proto3" json:"locked_at,omitempty"`
	ExpiresAt int64  `protobuf:"varint,3,opt,name=expires_at,json=expiresAt,proto3" json:"expires_at,omitempty"`
	// contains filtered or unexported fields
}

func (*LockHolder) Descriptor deprecated 

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

Deprecated: Use LockHolder.ProtoReflect.Descriptor instead.

func (*LockHolder) GetExpiresAt 

func (x *LockHolder) GetExpiresAt() int64

func (*LockHolder) GetLockedAt 

func (x *LockHolder) GetLockedAt() int64

func (*LockHolder) GetProcessId 

func (x *LockHolder) GetProcessId() string

func (*LockHolder) ProtoMessage 

func (*LockHolder) ProtoMessage()

func (*LockHolder) ProtoReflect 

func (x *LockHolder) ProtoReflect() protoreflect.Message

func (*LockHolder) Reset 

func (x *LockHolder) Reset()

func (*LockHolder) String 

func (x *LockHolder) String() string

type LockId 

type LockId struct {
	AccountId   uint64 `protobuf:"varint,1,opt,name=account_id,json=accountId,proto3" json:"account_id,omitempty"`
	NamespaceId uint32 `protobuf:"varint,2,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	LockName    string `protobuf:"bytes,3,opt,name=lock_name,json=lockName,proto3" json:"lock_name,omitempty"`
	// contains filtered or unexported fields
}

func (*LockId) Descriptor deprecated 

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

Deprecated: Use LockId.ProtoReflect.Descriptor instead.

func (*LockId) GetAccountId 

func (x *LockId) GetAccountId() uint64

func (*LockId) GetLockName 

func (x *LockId) GetLockName() string

func (*LockId) GetNamespaceId 

func (x *LockId) GetNamespaceId() uint32

func (*LockId) ProtoMessage 

func (*LockId) ProtoMessage()

func (*LockId) ProtoReflect 

func (x *LockId) ProtoReflect() protoreflect.Message

func (*LockId) Reset 

func (x *LockId) Reset()

func (*LockId) String 

func (x *LockId) String() string

type LockState 

type LockState int32
const (
	LockState_UNLOCKED         LockState = 0
	LockState_SHARED_LOCKED    LockState = 1
	LockState_EXCLUSIVE_LOCKED LockState = 2
)

func (LockState) Descriptor 

func (LockState) Descriptor() protoreflect.EnumDescriptor

func (LockState) Enum 

func (x LockState) Enum() *LockState

func (LockState) EnumDescriptor deprecated 

func (LockState) EnumDescriptor() ([]byte, []int)

Deprecated: Use LockState.Descriptor instead.

func (LockState) Number 

func (x LockState) Number() protoreflect.EnumNumber

func (LockState) String 

func (x LockState) String() string

func (LockState) Type 

func (LockState) Type() protoreflect.EnumType

type LocksCounter 

type LocksCounter struct {
	NamespaceId   *NamespaceId `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	NumberOfLocks int64        `protobuf:"varint,2,opt,name=number_of_locks,json=numberOfLocks,proto3" json:"number_of_locks,omitempty"`
	// contains filtered or unexported fields
}

func (*LocksCounter) Descriptor deprecated 

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

Deprecated: Use LocksCounter.ProtoReflect.Descriptor instead.

func (*LocksCounter) GetNamespaceId 

func (x *LocksCounter) GetNamespaceId() *NamespaceId

func (*LocksCounter) GetNumberOfLocks 

func (x *LocksCounter) GetNumberOfLocks() int64

func (*LocksCounter) MarshalBinary 

func (m *LocksCounter) MarshalBinary() (data []byte, err error)

func (*LocksCounter) ProtoMessage 

func (*LocksCounter) ProtoMessage()

func (*LocksCounter) ProtoReflect 

func (x *LocksCounter) ProtoReflect() protoreflect.Message

func (*LocksCounter) Reset 

func (x *LocksCounter) Reset()

func (*LocksCounter) String 

func (x *LocksCounter) String() string

func (*LocksCounter) UnmarshalBinary 

func (m *LocksCounter) UnmarshalBinary(data []byte) error

type LocksDeleteNamespaceRequest 

type LocksDeleteNamespaceRequest struct {
	NamespaceId *NamespaceId `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	RecordId    uint64       `protobuf:"varint,2,opt,name=record_id,json=recordId,proto3" json:"record_id,omitempty"`
	Now         int64        `protobuf:"varint,3,opt,name=now,proto3" json:"now,omitempty"`
	// contains filtered or unexported fields
}

func (*LocksDeleteNamespaceRequest) Descriptor deprecated 

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

Deprecated: Use LocksDeleteNamespaceRequest.ProtoReflect.Descriptor instead.

func (*LocksDeleteNamespaceRequest) GetNamespaceId 

func (x *LocksDeleteNamespaceRequest) GetNamespaceId() *NamespaceId

func (*LocksDeleteNamespaceRequest) GetNow 

func (x *LocksDeleteNamespaceRequest) GetNow() int64

func (*LocksDeleteNamespaceRequest) GetRecordId 

func (x *LocksDeleteNamespaceRequest) GetRecordId() uint64

func (*LocksDeleteNamespaceRequest) ProtoMessage 

func (*LocksDeleteNamespaceRequest) ProtoMessage()

func (*LocksDeleteNamespaceRequest) ProtoReflect 

func (x *LocksDeleteNamespaceRequest) ProtoReflect() protoreflect.Message

func (*LocksDeleteNamespaceRequest) Reset 

func (x *LocksDeleteNamespaceRequest) Reset()

func (*LocksDeleteNamespaceRequest) String 

func (x *LocksDeleteNamespaceRequest) String() string

type LocksDeleteNamespaceResponse 

type LocksDeleteNamespaceResponse struct {
	// contains filtered or unexported fields
}

func (*LocksDeleteNamespaceResponse) Descriptor deprecated 

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

Deprecated: Use LocksDeleteNamespaceResponse.ProtoReflect.Descriptor instead.

func (*LocksDeleteNamespaceResponse) ProtoMessage 

func (*LocksDeleteNamespaceResponse) ProtoMessage()

func (*LocksDeleteNamespaceResponse) ProtoReflect 

func (x *LocksDeleteNamespaceResponse) ProtoReflect() protoreflect.Message

func (*LocksDeleteNamespaceResponse) Reset 

func (x *LocksDeleteNamespaceResponse) Reset()

func (*LocksDeleteNamespaceResponse) String 

func (x *LocksDeleteNamespaceResponse) String() string

type LocksExpirationRecord 

type LocksExpirationRecord struct {
	LockId    *LockId `protobuf:"bytes,1,opt,name=lock_id,json=lockId,proto3" json:"lock_id,omitempty"`
	ExpiresAt int64   `protobuf:"varint,2,opt,name=expires_at,json=expiresAt,proto3" json:"expires_at,omitempty"`
	// contains filtered or unexported fields
}

func (*LocksExpirationRecord) Descriptor deprecated 

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

Deprecated: Use LocksExpirationRecord.ProtoReflect.Descriptor instead.

func (*LocksExpirationRecord) GetExpiresAt 

func (x *LocksExpirationRecord) GetExpiresAt() int64

func (*LocksExpirationRecord) GetLockId 

func (x *LocksExpirationRecord) GetLockId() *LockId

func (*LocksExpirationRecord) MarshalBinary 

func (m *LocksExpirationRecord) MarshalBinary() (data []byte, err error)

func (*LocksExpirationRecord) ProtoMessage 

func (*LocksExpirationRecord) ProtoMessage()

func (*LocksExpirationRecord) ProtoReflect 

func (x *LocksExpirationRecord) ProtoReflect() protoreflect.Message

func (*LocksExpirationRecord) Reset 

func (x *LocksExpirationRecord) Reset()

func (*LocksExpirationRecord) String 

func (x *LocksExpirationRecord) String() string

func (*LocksExpirationRecord) UnmarshalBinary 

func (m *LocksExpirationRecord) UnmarshalBinary(data []byte) error

type LocksGarbageCollectionRecord 

type LocksGarbageCollectionRecord struct {
	Id          uint64       `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	NamespaceId *NamespaceId `protobuf:"bytes,2,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	// contains filtered or unexported fields
}

func (*LocksGarbageCollectionRecord) Descriptor deprecated 

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

Deprecated: Use LocksGarbageCollectionRecord.ProtoReflect.Descriptor instead.

func (*LocksGarbageCollectionRecord) GetId 

func (x *LocksGarbageCollectionRecord) GetId() uint64

func (*LocksGarbageCollectionRecord) GetNamespaceId 

func (x *LocksGarbageCollectionRecord) GetNamespaceId() *NamespaceId

func (*LocksGarbageCollectionRecord) MarshalBinary 

func (m *LocksGarbageCollectionRecord) MarshalBinary() (data []byte, err error)

func (*LocksGarbageCollectionRecord) ProtoMessage 

func (*LocksGarbageCollectionRecord) ProtoMessage()

func (*LocksGarbageCollectionRecord) ProtoReflect 

func (x *LocksGarbageCollectionRecord) ProtoReflect() protoreflect.Message

func (*LocksGarbageCollectionRecord) Reset 

func (x *LocksGarbageCollectionRecord) Reset()

func (*LocksGarbageCollectionRecord) String 

func (x *LocksGarbageCollectionRecord) String() string

func (*LocksGarbageCollectionRecord) UnmarshalBinary 

func (m *LocksGarbageCollectionRecord) UnmarshalBinary(data []byte) error

type Namespace 

type Namespace struct {
	Id          *NamespaceId `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name        string       `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Description string       `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	CreatedAt   int64        `protobuf:"varint,4,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt   int64        `protobuf:"varint,5,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

func (*Namespace) Descriptor deprecated 

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

Deprecated: Use Namespace.ProtoReflect.Descriptor instead.

func (*Namespace) GetCreatedAt 

func (x *Namespace) GetCreatedAt() int64

func (*Namespace) GetDescription 

func (x *Namespace) GetDescription() string

func (*Namespace) GetId 

func (x *Namespace) GetId() *NamespaceId

func (*Namespace) GetName 

func (x *Namespace) GetName() string

func (*Namespace) GetUpdatedAt 

func (x *Namespace) GetUpdatedAt() int64

func (*Namespace) MarshalBinary 

func (m *Namespace) MarshalBinary() (data []byte, err error)

func (*Namespace) ProtoMessage 

func (*Namespace) ProtoMessage()

func (*Namespace) ProtoReflect 

func (x *Namespace) ProtoReflect() protoreflect.Message

func (*Namespace) Reset 

func (x *Namespace) Reset()

func (*Namespace) String 

func (x *Namespace) String() string

func (*Namespace) UnmarshalBinary 

func (m *Namespace) UnmarshalBinary(data []byte) error

type NamespaceId 

type NamespaceId struct {
	AccountId   uint64 `protobuf:"varint,1,opt,name=account_id,json=accountId,proto3" json:"account_id,omitempty"`
	NamespaceId uint32 `protobuf:"varint,2,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	// contains filtered or unexported fields
}

func (*NamespaceId) Descriptor deprecated 

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

Deprecated: Use NamespaceId.ProtoReflect.Descriptor instead.

func (*NamespaceId) GetAccountId 

func (x *NamespaceId) GetAccountId() uint64

func (*NamespaceId) GetNamespaceId 

func (x *NamespaceId) GetNamespaceId() uint32

func (*NamespaceId) ProtoMessage 

func (*NamespaceId) ProtoMessage()

func (*NamespaceId) ProtoReflect 

func (x *NamespaceId) ProtoReflect() protoreflect.Message

func (*NamespaceId) Reset 

func (x *NamespaceId) Reset()

func (*NamespaceId) String 

func (x *NamespaceId) String() string

type NamespacesCounter 

type NamespacesCounter struct {
	AccountId          uint64 `protobuf:"varint,1,opt,name=account_id,json=accountId,proto3" json:"account_id,omitempty"`
	NumberOfNamespaces int64  `protobuf:"varint,2,opt,name=number_of_namespaces,json=numberOfNamespaces,proto3" json:"number_of_namespaces,omitempty"`
	// contains filtered or unexported fields
}

func (*NamespacesCounter) Descriptor deprecated 

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

Deprecated: Use NamespacesCounter.ProtoReflect.Descriptor instead.

func (*NamespacesCounter) GetAccountId 

func (x *NamespacesCounter) GetAccountId() uint64

func (*NamespacesCounter) GetNumberOfNamespaces 

func (x *NamespacesCounter) GetNumberOfNamespaces() int64

func (*NamespacesCounter) MarshalBinary 

func (m *NamespacesCounter) MarshalBinary() (data []byte, err error)

func (*NamespacesCounter) ProtoMessage 

func (*NamespacesCounter) ProtoMessage()

func (*NamespacesCounter) ProtoReflect 

func (x *NamespacesCounter) ProtoReflect() protoreflect.Message

func (*NamespacesCounter) Reset 

func (x *NamespacesCounter) Reset()

func (*NamespacesCounter) String 

func (x *NamespacesCounter) String() string

func (*NamespacesCounter) UnmarshalBinary 

func (m *NamespacesCounter) UnmarshalBinary(data []byte) error

type PaginationToken 

type PaginationToken struct {
	Type  PaginationToken_Type `protobuf:"varint,1,opt,name=type,proto3,enum=com.evrblk.grackle.corepb.PaginationToken_Type" json:"type,omitempty"`
	Value []byte               `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*PaginationToken) Descriptor deprecated 

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

Deprecated: Use PaginationToken.ProtoReflect.Descriptor instead.

func (*PaginationToken) GetType 

func (x *PaginationToken) GetType() PaginationToken_Type

func (*PaginationToken) GetValue 

func (x *PaginationToken) GetValue() []byte

func (*PaginationToken) ProtoMessage 

func (*PaginationToken) ProtoMessage()

func (*PaginationToken) ProtoReflect 

func (x *PaginationToken) ProtoReflect() protoreflect.Message

func (*PaginationToken) Reset 

func (x *PaginationToken) Reset()

func (*PaginationToken) String 

func (x *PaginationToken) String() string

type PaginationToken_Type 

type PaginationToken_Type int32
const (
	PaginationToken_NEXT     PaginationToken_Type = 0
	PaginationToken_PREVIOUS PaginationToken_Type = 1
)

func (PaginationToken_Type) Descriptor 

func (PaginationToken_Type) Descriptor() protoreflect.EnumDescriptor

func (PaginationToken_Type) Enum 

func (x PaginationToken_Type) Enum() *PaginationToken_Type

func (PaginationToken_Type) EnumDescriptor deprecated 

func (PaginationToken_Type) EnumDescriptor() ([]byte, []int)

Deprecated: Use PaginationToken_Type.Descriptor instead.

func (PaginationToken_Type) Number 

func (x PaginationToken_Type) Number() protoreflect.EnumNumber

func (PaginationToken_Type) String 

func (x PaginationToken_Type) String() string

func (PaginationToken_Type) Type 

func (PaginationToken_Type) Type() protoreflect.EnumType

type ReleaseLockRequest 

type ReleaseLockRequest struct {
	LockId    *LockId `protobuf:"bytes,1,opt,name=lock_id,json=lockId,proto3" json:"lock_id,omitempty"`
	ProcessId string  `protobuf:"bytes,2,opt,name=process_id,json=processId,proto3" json:"process_id,omitempty"`
	Now       int64   `protobuf:"varint,3,opt,name=now,proto3" json:"now,omitempty"`
	// contains filtered or unexported fields
}

func (*ReleaseLockRequest) Descriptor deprecated 

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

Deprecated: Use ReleaseLockRequest.ProtoReflect.Descriptor instead.

func (*ReleaseLockRequest) GetLockId 

func (x *ReleaseLockRequest) GetLockId() *LockId

func (*ReleaseLockRequest) GetNow 

func (x *ReleaseLockRequest) GetNow() int64

func (*ReleaseLockRequest) GetProcessId 

func (x *ReleaseLockRequest) GetProcessId() string

func (*ReleaseLockRequest) ProtoMessage 

func (*ReleaseLockRequest) ProtoMessage()

func (*ReleaseLockRequest) ProtoReflect 

func (x *ReleaseLockRequest) ProtoReflect() protoreflect.Message

func (*ReleaseLockRequest) Reset 

func (x *ReleaseLockRequest) Reset()

func (*ReleaseLockRequest) String 

func (x *ReleaseLockRequest) String() string

type ReleaseLockResponse 

type ReleaseLockResponse struct {
	Lock *Lock `protobuf:"bytes,1,opt,name=lock,proto3" json:"lock,omitempty"`
	// contains filtered or unexported fields
}

func (*ReleaseLockResponse) Descriptor deprecated 

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

Deprecated: Use ReleaseLockResponse.ProtoReflect.Descriptor instead.

func (*ReleaseLockResponse) GetLock 

func (x *ReleaseLockResponse) GetLock() *Lock

func (*ReleaseLockResponse) ProtoMessage 

func (*ReleaseLockResponse) ProtoMessage()

func (*ReleaseLockResponse) ProtoReflect 

func (x *ReleaseLockResponse) ProtoReflect() protoreflect.Message

func (*ReleaseLockResponse) Reset 

func (x *ReleaseLockResponse) Reset()

func (*ReleaseLockResponse) String 

func (x *ReleaseLockResponse) String() string

type ReleaseSemaphoreRequest 

type ReleaseSemaphoreRequest struct {
	NamespaceId   *NamespaceId `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	SemaphoreName string       `protobuf:"bytes,2,opt,name=semaphore_name,json=semaphoreName,proto3" json:"semaphore_name,omitempty"`
	ProcessId     string       `protobuf:"bytes,3,opt,name=process_id,json=processId,proto3" json:"process_id,omitempty"`
	Now           int64        `protobuf:"varint,4,opt,name=now,proto3" json:"now,omitempty"`
	// contains filtered or unexported fields
}

func (*ReleaseSemaphoreRequest) Descriptor deprecated 

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

Deprecated: Use ReleaseSemaphoreRequest.ProtoReflect.Descriptor instead.

func (*ReleaseSemaphoreRequest) GetNamespaceId 

func (x *ReleaseSemaphoreRequest) GetNamespaceId() *NamespaceId

func (*ReleaseSemaphoreRequest) GetNow 

func (x *ReleaseSemaphoreRequest) GetNow() int64

func (*ReleaseSemaphoreRequest) GetProcessId 

func (x *ReleaseSemaphoreRequest) GetProcessId() string

func (*ReleaseSemaphoreRequest) GetSemaphoreName 

func (x *ReleaseSemaphoreRequest) GetSemaphoreName() string

func (*ReleaseSemaphoreRequest) ProtoMessage 

func (*ReleaseSemaphoreRequest) ProtoMessage()

func (*ReleaseSemaphoreRequest) ProtoReflect 

func (x *ReleaseSemaphoreRequest) ProtoReflect() protoreflect.Message

func (*ReleaseSemaphoreRequest) Reset 

func (x *ReleaseSemaphoreRequest) Reset()

func (*ReleaseSemaphoreRequest) String 

func (x *ReleaseSemaphoreRequest) String() string

type ReleaseSemaphoreResponse 

type ReleaseSemaphoreResponse struct {
	Semaphore *Semaphore `protobuf:"bytes,1,opt,name=semaphore,proto3" json:"semaphore,omitempty"`
	// contains filtered or unexported fields
}

func (*ReleaseSemaphoreResponse) Descriptor deprecated 

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

Deprecated: Use ReleaseSemaphoreResponse.ProtoReflect.Descriptor instead.

func (*ReleaseSemaphoreResponse) GetSemaphore 

func (x *ReleaseSemaphoreResponse) GetSemaphore() *Semaphore

func (*ReleaseSemaphoreResponse) ProtoMessage 

func (*ReleaseSemaphoreResponse) ProtoMessage()

func (*ReleaseSemaphoreResponse) ProtoReflect 

func (x *ReleaseSemaphoreResponse) ProtoReflect() protoreflect.Message

func (*ReleaseSemaphoreResponse) Reset 

func (x *ReleaseSemaphoreResponse) Reset()

func (*ReleaseSemaphoreResponse) String 

func (x *ReleaseSemaphoreResponse) String() string

type RunBarriersGarbageCollectionRequest 

type RunBarriersGarbageCollectionRequest struct {
	Now                   int64 `protobuf:"varint,1,opt,name=now,proto3" json:"now,omitempty"`
	GcRecordsPageSize     int64 `protobuf:"varint,2,opt,name=gc_records_page_size,json=gcRecordsPageSize,proto3" json:"gc_records_page_size,omitempty"`
	GcRecordLocksPageSize int64 `` /* 131-byte string literal not displayed */
	MaxVisitedLocks       int64 `protobuf:"varint,4,opt,name=max_visited_locks,json=maxVisitedLocks,proto3" json:"max_visited_locks,omitempty"`
	// contains filtered or unexported fields
}

func (*RunBarriersGarbageCollectionRequest) Descriptor deprecated 

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

Deprecated: Use RunBarriersGarbageCollectionRequest.ProtoReflect.Descriptor instead.

func (*RunBarriersGarbageCollectionRequest) GetGcRecordLocksPageSize 

func (x *RunBarriersGarbageCollectionRequest) GetGcRecordLocksPageSize() int64

func (*RunBarriersGarbageCollectionRequest) GetGcRecordsPageSize 

func (x *RunBarriersGarbageCollectionRequest) GetGcRecordsPageSize() int64

func (*RunBarriersGarbageCollectionRequest) GetMaxVisitedLocks 

func (x *RunBarriersGarbageCollectionRequest) GetMaxVisitedLocks() int64

func (*RunBarriersGarbageCollectionRequest) GetNow 

func (x *RunBarriersGarbageCollectionRequest) GetNow() int64

func (*RunBarriersGarbageCollectionRequest) ProtoMessage 

func (*RunBarriersGarbageCollectionRequest) ProtoMessage()

func (*RunBarriersGarbageCollectionRequest) ProtoReflect 

func (x *RunBarriersGarbageCollectionRequest) ProtoReflect() protoreflect.Message

func (*RunBarriersGarbageCollectionRequest) Reset 

func (x *RunBarriersGarbageCollectionRequest) Reset()

func (*RunBarriersGarbageCollectionRequest) String 

func (x *RunBarriersGarbageCollectionRequest) String() string

type RunBarriersGarbageCollectionResponse 

type RunBarriersGarbageCollectionResponse struct {
	// contains filtered or unexported fields
}

func (*RunBarriersGarbageCollectionResponse) Descriptor deprecated 

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

Deprecated: Use RunBarriersGarbageCollectionResponse.ProtoReflect.Descriptor instead.

func (*RunBarriersGarbageCollectionResponse) ProtoMessage 

func (*RunBarriersGarbageCollectionResponse) ProtoMessage()

func (*RunBarriersGarbageCollectionResponse) ProtoReflect 

func (x *RunBarriersGarbageCollectionResponse) ProtoReflect() protoreflect.Message

func (*RunBarriersGarbageCollectionResponse) Reset 

func (x *RunBarriersGarbageCollectionResponse) Reset()

func (*RunBarriersGarbageCollectionResponse) String 

func (x *RunBarriersGarbageCollectionResponse) String() string

type RunLocksGarbageCollectionRequest 

type RunLocksGarbageCollectionRequest struct {
	Now                   int64 `protobuf:"varint,1,opt,name=now,proto3" json:"now,omitempty"`
	GcRecordsPageSize     int64 `protobuf:"varint,2,opt,name=gc_records_page_size,json=gcRecordsPageSize,proto3" json:"gc_records_page_size,omitempty"`
	GcRecordLocksPageSize int64 `` /* 131-byte string literal not displayed */
	MaxVisitedLocks       int64 `protobuf:"varint,4,opt,name=max_visited_locks,json=maxVisitedLocks,proto3" json:"max_visited_locks,omitempty"`
	// contains filtered or unexported fields
}

func (*RunLocksGarbageCollectionRequest) Descriptor deprecated 

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

Deprecated: Use RunLocksGarbageCollectionRequest.ProtoReflect.Descriptor instead.

func (*RunLocksGarbageCollectionRequest) GetGcRecordLocksPageSize 

func (x *RunLocksGarbageCollectionRequest) GetGcRecordLocksPageSize() int64

func (*RunLocksGarbageCollectionRequest) GetGcRecordsPageSize 

func (x *RunLocksGarbageCollectionRequest) GetGcRecordsPageSize() int64

func (*RunLocksGarbageCollectionRequest) GetMaxVisitedLocks 

func (x *RunLocksGarbageCollectionRequest) GetMaxVisitedLocks() int64

func (*RunLocksGarbageCollectionRequest) GetNow 

func (x *RunLocksGarbageCollectionRequest) GetNow() int64

func (*RunLocksGarbageCollectionRequest) ProtoMessage 

func (*RunLocksGarbageCollectionRequest) ProtoMessage()

func (*RunLocksGarbageCollectionRequest) ProtoReflect 

func (x *RunLocksGarbageCollectionRequest) ProtoReflect() protoreflect.Message

func (*RunLocksGarbageCollectionRequest) Reset 

func (x *RunLocksGarbageCollectionRequest) Reset()

func (*RunLocksGarbageCollectionRequest) String 

func (x *RunLocksGarbageCollectionRequest) String() string

type RunLocksGarbageCollectionResponse 

type RunLocksGarbageCollectionResponse struct {
	// contains filtered or unexported fields
}

func (*RunLocksGarbageCollectionResponse) Descriptor deprecated 

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

Deprecated: Use RunLocksGarbageCollectionResponse.ProtoReflect.Descriptor instead.

func (*RunLocksGarbageCollectionResponse) ProtoMessage 

func (*RunLocksGarbageCollectionResponse) ProtoMessage()

func (*RunLocksGarbageCollectionResponse) ProtoReflect 

func (x *RunLocksGarbageCollectionResponse) ProtoReflect() protoreflect.Message

func (*RunLocksGarbageCollectionResponse) Reset 

func (x *RunLocksGarbageCollectionResponse) Reset()

func (*RunLocksGarbageCollectionResponse) String 

func (x *RunLocksGarbageCollectionResponse) String() string

type RunSemaphoresGarbageCollectionRequest 

type RunSemaphoresGarbageCollectionRequest struct {
	Now                        int64 `protobuf:"varint,1,opt,name=now,proto3" json:"now,omitempty"`
	GcRecordsPageSize          int64 `protobuf:"varint,2,opt,name=gc_records_page_size,json=gcRecordsPageSize,proto3" json:"gc_records_page_size,omitempty"`
	GcRecordSemaphoresPageSize int64 `` /* 146-byte string literal not displayed */
	MaxVisitedSemaphores       int64 `protobuf:"varint,4,opt,name=max_visited_semaphores,json=maxVisitedSemaphores,proto3" json:"max_visited_semaphores,omitempty"`
	// contains filtered or unexported fields
}

func (*RunSemaphoresGarbageCollectionRequest) Descriptor deprecated 

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

Deprecated: Use RunSemaphoresGarbageCollectionRequest.ProtoReflect.Descriptor instead.

func (*RunSemaphoresGarbageCollectionRequest) GetGcRecordSemaphoresPageSize 

func (x *RunSemaphoresGarbageCollectionRequest) GetGcRecordSemaphoresPageSize() int64

func (*RunSemaphoresGarbageCollectionRequest) GetGcRecordsPageSize 

func (x *RunSemaphoresGarbageCollectionRequest) GetGcRecordsPageSize() int64

func (*RunSemaphoresGarbageCollectionRequest) GetMaxVisitedSemaphores 

func (x *RunSemaphoresGarbageCollectionRequest) GetMaxVisitedSemaphores() int64

func (*RunSemaphoresGarbageCollectionRequest) GetNow 

func (x *RunSemaphoresGarbageCollectionRequest) GetNow() int64

func (*RunSemaphoresGarbageCollectionRequest) ProtoMessage 

func (*RunSemaphoresGarbageCollectionRequest) ProtoMessage()

func (*RunSemaphoresGarbageCollectionRequest) ProtoReflect 

func (x *RunSemaphoresGarbageCollectionRequest) ProtoReflect() protoreflect.Message

func (*RunSemaphoresGarbageCollectionRequest) Reset 

func (x *RunSemaphoresGarbageCollectionRequest) Reset()

func (*RunSemaphoresGarbageCollectionRequest) String 

func (x *RunSemaphoresGarbageCollectionRequest) String() string

type RunSemaphoresGarbageCollectionResponse 

type RunSemaphoresGarbageCollectionResponse struct {
	// contains filtered or unexported fields
}

func (*RunSemaphoresGarbageCollectionResponse) Descriptor deprecated 

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

Deprecated: Use RunSemaphoresGarbageCollectionResponse.ProtoReflect.Descriptor instead.

func (*RunSemaphoresGarbageCollectionResponse) ProtoMessage 

func (*RunSemaphoresGarbageCollectionResponse) ProtoMessage()

func (*RunSemaphoresGarbageCollectionResponse) ProtoReflect 

func (x *RunSemaphoresGarbageCollectionResponse) ProtoReflect() protoreflect.Message

func (*RunSemaphoresGarbageCollectionResponse) Reset 

func (x *RunSemaphoresGarbageCollectionResponse) Reset()

func (*RunSemaphoresGarbageCollectionResponse) String 

func (x *RunSemaphoresGarbageCollectionResponse) String() string

type RunWaitGroupsGarbageCollectionRequest 

type RunWaitGroupsGarbageCollectionRequest struct {
	Now                        int64 `protobuf:"varint,1,opt,name=now,proto3" json:"now,omitempty"`
	GcRecordsPageSize          int64 `protobuf:"varint,2,opt,name=gc_records_page_size,json=gcRecordsPageSize,proto3" json:"gc_records_page_size,omitempty"`
	GcRecordWaitGroupsPageSize int64 `` /* 148-byte string literal not displayed */
	MaxDeletedObjects          int64 `protobuf:"varint,4,opt,name=max_deleted_objects,json=maxDeletedObjects,proto3" json:"max_deleted_objects,omitempty"`
	// contains filtered or unexported fields
}

func (*RunWaitGroupsGarbageCollectionRequest) Descriptor deprecated 

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

Deprecated: Use RunWaitGroupsGarbageCollectionRequest.ProtoReflect.Descriptor instead.

func (*RunWaitGroupsGarbageCollectionRequest) GetGcRecordWaitGroupsPageSize 

func (x *RunWaitGroupsGarbageCollectionRequest) GetGcRecordWaitGroupsPageSize() int64

func (*RunWaitGroupsGarbageCollectionRequest) GetGcRecordsPageSize 

func (x *RunWaitGroupsGarbageCollectionRequest) GetGcRecordsPageSize() int64

func (*RunWaitGroupsGarbageCollectionRequest) GetMaxDeletedObjects 

func (x *RunWaitGroupsGarbageCollectionRequest) GetMaxDeletedObjects() int64

func (*RunWaitGroupsGarbageCollectionRequest) GetNow 

func (x *RunWaitGroupsGarbageCollectionRequest) GetNow() int64

func (*RunWaitGroupsGarbageCollectionRequest) ProtoMessage 

func (*RunWaitGroupsGarbageCollectionRequest) ProtoMessage()

func (*RunWaitGroupsGarbageCollectionRequest) ProtoReflect 

func (x *RunWaitGroupsGarbageCollectionRequest) ProtoReflect() protoreflect.Message

func (*RunWaitGroupsGarbageCollectionRequest) Reset 

func (x *RunWaitGroupsGarbageCollectionRequest) Reset()

func (*RunWaitGroupsGarbageCollectionRequest) String 

func (x *RunWaitGroupsGarbageCollectionRequest) String() string

type RunWaitGroupsGarbageCollectionResponse 

type RunWaitGroupsGarbageCollectionResponse struct {
	// contains filtered or unexported fields
}

func (*RunWaitGroupsGarbageCollectionResponse) Descriptor deprecated 

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

Deprecated: Use RunWaitGroupsGarbageCollectionResponse.ProtoReflect.Descriptor instead.

func (*RunWaitGroupsGarbageCollectionResponse) ProtoMessage 

func (*RunWaitGroupsGarbageCollectionResponse) ProtoMessage()

func (*RunWaitGroupsGarbageCollectionResponse) ProtoReflect 

func (x *RunWaitGroupsGarbageCollectionResponse) ProtoReflect() protoreflect.Message

func (*RunWaitGroupsGarbageCollectionResponse) Reset 

func (x *RunWaitGroupsGarbageCollectionResponse) Reset()

func (*RunWaitGroupsGarbageCollectionResponse) String 

func (x *RunWaitGroupsGarbageCollectionResponse) String() string

type Semaphore 

type Semaphore struct {
	Id                      *SemaphoreId `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                    string       `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Description             string       `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	CreatedAt               int64        `protobuf:"varint,4,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt               int64        `protobuf:"varint,5,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	Permits                 uint64       `protobuf:"varint,6,opt,name=permits,proto3" json:"permits,omitempty"`
	ActiveHolds             uint64       `protobuf:"varint,7,opt,name=active_holds,json=activeHolds,proto3" json:"active_holds,omitempty"`
	ActiveHoldersCount      uint64       `protobuf:"varint,8,opt,name=active_holders_count,json=activeHoldersCount,proto3" json:"active_holders_count,omitempty"`
	EarliestHolderExpiresAt int64        `` /* 135-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Semaphore) Descriptor deprecated 

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

Deprecated: Use Semaphore.ProtoReflect.Descriptor instead.

func (*Semaphore) GetActiveHoldersCount 

func (x *Semaphore) GetActiveHoldersCount() uint64

func (*Semaphore) GetActiveHolds 

func (x *Semaphore) GetActiveHolds() uint64

func (*Semaphore) GetCreatedAt 

func (x *Semaphore) GetCreatedAt() int64

func (*Semaphore) GetDescription 

func (x *Semaphore) GetDescription() string

func (*Semaphore) GetEarliestHolderExpiresAt 

func (x *Semaphore) GetEarliestHolderExpiresAt() int64

func (*Semaphore) GetId 

func (x *Semaphore) GetId() *SemaphoreId

func (*Semaphore) GetName 

func (x *Semaphore) GetName() string

func (*Semaphore) GetPermits 

func (x *Semaphore) GetPermits() uint64

func (*Semaphore) GetUpdatedAt 

func (x *Semaphore) GetUpdatedAt() int64

func (*Semaphore) MarshalBinary 

func (m *Semaphore) MarshalBinary() (data []byte, err error)

func (*Semaphore) ProtoMessage 

func (*Semaphore) ProtoMessage()

func (*Semaphore) ProtoReflect 

func (x *Semaphore) ProtoReflect() protoreflect.Message

func (*Semaphore) Reset 

func (x *Semaphore) Reset()

func (*Semaphore) String 

func (x *Semaphore) String() string

func (*Semaphore) UnmarshalBinary 

func (m *Semaphore) UnmarshalBinary(data []byte) error

type SemaphoreHolder 

type SemaphoreHolder struct {
	Id        *SemaphoreHolderId `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	LockedAt  int64              `protobuf:"varint,2,opt,name=locked_at,json=lockedAt,proto3" json:"locked_at,omitempty"`
	ExpiresAt int64              `protobuf:"varint,3,opt,name=expires_at,json=expiresAt,proto3" json:"expires_at,omitempty"`
	Weight    uint64             `protobuf:"varint,4,opt,name=weight,proto3" json:"weight,omitempty"`
	// contains filtered or unexported fields
}

func (*SemaphoreHolder) Descriptor deprecated 

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

Deprecated: Use SemaphoreHolder.ProtoReflect.Descriptor instead.

func (*SemaphoreHolder) GetExpiresAt 

func (x *SemaphoreHolder) GetExpiresAt() int64

func (*SemaphoreHolder) GetId 

func (x *SemaphoreHolder) GetId() *SemaphoreHolderId

func (*SemaphoreHolder) GetLockedAt 

func (x *SemaphoreHolder) GetLockedAt() int64

func (*SemaphoreHolder) GetWeight 

func (x *SemaphoreHolder) GetWeight() uint64

func (*SemaphoreHolder) MarshalBinary 

func (m *SemaphoreHolder) MarshalBinary() (data []byte, err error)

func (*SemaphoreHolder) ProtoMessage 

func (*SemaphoreHolder) ProtoMessage()

func (*SemaphoreHolder) ProtoReflect 

func (x *SemaphoreHolder) ProtoReflect() protoreflect.Message

func (*SemaphoreHolder) Reset 

func (x *SemaphoreHolder) Reset()

func (*SemaphoreHolder) String 

func (x *SemaphoreHolder) String() string

func (*SemaphoreHolder) UnmarshalBinary 

func (m *SemaphoreHolder) UnmarshalBinary(data []byte) error

type SemaphoreHolderId 

type SemaphoreHolderId struct {
	AccountId   uint64 `protobuf:"varint,1,opt,name=account_id,json=accountId,proto3" json:"account_id,omitempty"`
	NamespaceId uint32 `protobuf:"varint,2,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	SemaphoreId uint64 `protobuf:"varint,3,opt,name=semaphore_id,json=semaphoreId,proto3" json:"semaphore_id,omitempty"`
	ProcessId   string `protobuf:"bytes,4,opt,name=process_id,json=processId,proto3" json:"process_id,omitempty"`
	// contains filtered or unexported fields
}

func (*SemaphoreHolderId) Descriptor deprecated 

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

Deprecated: Use SemaphoreHolderId.ProtoReflect.Descriptor instead.

func (*SemaphoreHolderId) GetAccountId 

func (x *SemaphoreHolderId) GetAccountId() uint64

func (*SemaphoreHolderId) GetNamespaceId 

func (x *SemaphoreHolderId) GetNamespaceId() uint32

func (*SemaphoreHolderId) GetProcessId 

func (x *SemaphoreHolderId) GetProcessId() string

func (*SemaphoreHolderId) GetSemaphoreId 

func (x *SemaphoreHolderId) GetSemaphoreId() uint64

func (*SemaphoreHolderId) ProtoMessage 

func (*SemaphoreHolderId) ProtoMessage()

func (*SemaphoreHolderId) ProtoReflect 

func (x *SemaphoreHolderId) ProtoReflect() protoreflect.Message

func (*SemaphoreHolderId) Reset 

func (x *SemaphoreHolderId) Reset()

func (*SemaphoreHolderId) String 

func (x *SemaphoreHolderId) String() string

type SemaphoreId 

type SemaphoreId struct {
	AccountId   uint64 `protobuf:"varint,1,opt,name=account_id,json=accountId,proto3" json:"account_id,omitempty"`
	NamespaceId uint32 `protobuf:"varint,2,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	SemaphoreId uint64 `protobuf:"varint,3,opt,name=semaphore_id,json=semaphoreId,proto3" json:"semaphore_id,omitempty"`
	// contains filtered or unexported fields
}

func (*SemaphoreId) Descriptor deprecated 

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

Deprecated: Use SemaphoreId.ProtoReflect.Descriptor instead.

func (*SemaphoreId) GetAccountId 

func (x *SemaphoreId) GetAccountId() uint64

func (*SemaphoreId) GetNamespaceId 

func (x *SemaphoreId) GetNamespaceId() uint32

func (*SemaphoreId) GetSemaphoreId 

func (x *SemaphoreId) GetSemaphoreId() uint64

func (*SemaphoreId) ProtoMessage 

func (*SemaphoreId) ProtoMessage()

func (*SemaphoreId) ProtoReflect 

func (x *SemaphoreId) ProtoReflect() protoreflect.Message

func (*SemaphoreId) Reset 

func (x *SemaphoreId) Reset()

func (*SemaphoreId) String 

func (x *SemaphoreId) String() string

type SemaphoresCounter 

type SemaphoresCounter struct {
	NamespaceId        *NamespaceId `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	NumberOfSemaphores int64        `protobuf:"varint,2,opt,name=number_of_semaphores,json=numberOfSemaphores,proto3" json:"number_of_semaphores,omitempty"`
	// contains filtered or unexported fields
}

func (*SemaphoresCounter) Descriptor deprecated 

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

Deprecated: Use SemaphoresCounter.ProtoReflect.Descriptor instead.

func (*SemaphoresCounter) GetNamespaceId 

func (x *SemaphoresCounter) GetNamespaceId() *NamespaceId

func (*SemaphoresCounter) GetNumberOfSemaphores 

func (x *SemaphoresCounter) GetNumberOfSemaphores() int64

func (*SemaphoresCounter) MarshalBinary 

func (m *SemaphoresCounter) MarshalBinary() (data []byte, err error)

func (*SemaphoresCounter) ProtoMessage 

func (*SemaphoresCounter) ProtoMessage()

func (*SemaphoresCounter) ProtoReflect 

func (x *SemaphoresCounter) ProtoReflect() protoreflect.Message

func (*SemaphoresCounter) Reset 

func (x *SemaphoresCounter) Reset()

func (*SemaphoresCounter) String 

func (x *SemaphoresCounter) String() string

func (*SemaphoresCounter) UnmarshalBinary 

func (m *SemaphoresCounter) UnmarshalBinary(data []byte) error

type SemaphoresDeleteNamespaceRequest 

type SemaphoresDeleteNamespaceRequest struct {
	RecordId    uint64       `protobuf:"varint,1,opt,name=record_id,json=recordId,proto3" json:"record_id,omitempty"`
	NamespaceId *NamespaceId `protobuf:"bytes,2,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	Now         int64        `protobuf:"varint,3,opt,name=now,proto3" json:"now,omitempty"`
	// contains filtered or unexported fields
}

func (*SemaphoresDeleteNamespaceRequest) Descriptor deprecated 

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

Deprecated: Use SemaphoresDeleteNamespaceRequest.ProtoReflect.Descriptor instead.

func (*SemaphoresDeleteNamespaceRequest) GetNamespaceId 

func (x *SemaphoresDeleteNamespaceRequest) GetNamespaceId() *NamespaceId

func (*SemaphoresDeleteNamespaceRequest) GetNow 

func (x *SemaphoresDeleteNamespaceRequest) GetNow() int64

func (*SemaphoresDeleteNamespaceRequest) GetRecordId 

func (x *SemaphoresDeleteNamespaceRequest) GetRecordId() uint64

func (*SemaphoresDeleteNamespaceRequest) ProtoMessage 

func (*SemaphoresDeleteNamespaceRequest) ProtoMessage()

func (*SemaphoresDeleteNamespaceRequest) ProtoReflect 

func (x *SemaphoresDeleteNamespaceRequest) ProtoReflect() protoreflect.Message

func (*SemaphoresDeleteNamespaceRequest) Reset 

func (x *SemaphoresDeleteNamespaceRequest) Reset()

func (*SemaphoresDeleteNamespaceRequest) String 

func (x *SemaphoresDeleteNamespaceRequest) String() string

type SemaphoresDeleteNamespaceResponse 

type SemaphoresDeleteNamespaceResponse struct {
	// contains filtered or unexported fields
}

func (*SemaphoresDeleteNamespaceResponse) Descriptor deprecated 

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

Deprecated: Use SemaphoresDeleteNamespaceResponse.ProtoReflect.Descriptor instead.

func (*SemaphoresDeleteNamespaceResponse) ProtoMessage 

func (*SemaphoresDeleteNamespaceResponse) ProtoMessage()

func (*SemaphoresDeleteNamespaceResponse) ProtoReflect 

func (x *SemaphoresDeleteNamespaceResponse) ProtoReflect() protoreflect.Message

func (*SemaphoresDeleteNamespaceResponse) Reset 

func (x *SemaphoresDeleteNamespaceResponse) Reset()

func (*SemaphoresDeleteNamespaceResponse) String 

func (x *SemaphoresDeleteNamespaceResponse) String() string

type SemaphoresExpirationRecord 

type SemaphoresExpirationRecord struct {
	SemaphoreId *SemaphoreId `protobuf:"bytes,1,opt,name=semaphore_id,json=semaphoreId,proto3" json:"semaphore_id,omitempty"`
	ExpiresAt   int64        `protobuf:"varint,2,opt,name=expires_at,json=expiresAt,proto3" json:"expires_at,omitempty"`
	// contains filtered or unexported fields
}

func (*SemaphoresExpirationRecord) Descriptor deprecated 

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

Deprecated: Use SemaphoresExpirationRecord.ProtoReflect.Descriptor instead.

func (*SemaphoresExpirationRecord) GetExpiresAt 

func (x *SemaphoresExpirationRecord) GetExpiresAt() int64

func (*SemaphoresExpirationRecord) GetSemaphoreId 

func (x *SemaphoresExpirationRecord) GetSemaphoreId() *SemaphoreId

func (*SemaphoresExpirationRecord) MarshalBinary 

func (m *SemaphoresExpirationRecord) MarshalBinary() (data []byte, err error)

func (*SemaphoresExpirationRecord) ProtoMessage 

func (*SemaphoresExpirationRecord) ProtoMessage()

func (*SemaphoresExpirationRecord) ProtoReflect 

func (x *SemaphoresExpirationRecord) ProtoReflect() protoreflect.Message

func (*SemaphoresExpirationRecord) Reset 

func (x *SemaphoresExpirationRecord) Reset()

func (*SemaphoresExpirationRecord) String 

func (x *SemaphoresExpirationRecord) String() string

func (*SemaphoresExpirationRecord) UnmarshalBinary 

func (m *SemaphoresExpirationRecord) UnmarshalBinary(data []byte) error

type SemaphoresGarbageCollectionRecord 

type SemaphoresGarbageCollectionRecord struct {
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Types that are valid to be assigned to Record:
	//
	//	*SemaphoresGarbageCollectionRecord_NamespaceId
	//	*SemaphoresGarbageCollectionRecord_SemaphoreId
	Record isSemaphoresGarbageCollectionRecord_Record `protobuf_oneof:"record"`
	// contains filtered or unexported fields
}

func (*SemaphoresGarbageCollectionRecord) Descriptor deprecated 

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

Deprecated: Use SemaphoresGarbageCollectionRecord.ProtoReflect.Descriptor instead.

func (*SemaphoresGarbageCollectionRecord) GetId 

func (x *SemaphoresGarbageCollectionRecord) GetId() uint64

func (*SemaphoresGarbageCollectionRecord) GetNamespaceId 

func (x *SemaphoresGarbageCollectionRecord) GetNamespaceId() *NamespaceId

func (*SemaphoresGarbageCollectionRecord) GetRecord 

func (x *SemaphoresGarbageCollectionRecord) GetRecord() isSemaphoresGarbageCollectionRecord_Record

func (*SemaphoresGarbageCollectionRecord) GetSemaphoreId 

func (x *SemaphoresGarbageCollectionRecord) GetSemaphoreId() *SemaphoreId

func (*SemaphoresGarbageCollectionRecord) MarshalBinary 

func (m *SemaphoresGarbageCollectionRecord) MarshalBinary() (data []byte, err error)

func (*SemaphoresGarbageCollectionRecord) ProtoMessage 

func (*SemaphoresGarbageCollectionRecord) ProtoMessage()

func (*SemaphoresGarbageCollectionRecord) ProtoReflect 

func (x *SemaphoresGarbageCollectionRecord) ProtoReflect() protoreflect.Message

func (*SemaphoresGarbageCollectionRecord) Reset 

func (x *SemaphoresGarbageCollectionRecord) Reset()

func (*SemaphoresGarbageCollectionRecord) String 

func (x *SemaphoresGarbageCollectionRecord) String() string

func (*SemaphoresGarbageCollectionRecord) UnmarshalBinary 

func (m *SemaphoresGarbageCollectionRecord) UnmarshalBinary(data []byte) error

type SemaphoresGarbageCollectionRecord_NamespaceId 

type SemaphoresGarbageCollectionRecord_NamespaceId struct {
	NamespaceId *NamespaceId `protobuf:"bytes,2,opt,name=namespace_id,json=namespaceId,proto3,oneof"`
}

type SemaphoresGarbageCollectionRecord_SemaphoreId 

type SemaphoresGarbageCollectionRecord_SemaphoreId struct {
	SemaphoreId *SemaphoreId `protobuf:"bytes,3,opt,name=semaphore_id,json=semaphoreId,proto3,oneof"`
}

type UpdateBarrierRequest 

type UpdateBarrierRequest struct {
	BarrierId         *BarrierId `protobuf:"bytes,1,opt,name=barrier_id,json=barrierId,proto3" json:"barrier_id,omitempty"`
	Description       string     `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	ExpectedProcesses uint64     `protobuf:"varint,3,opt,name=expected_processes,json=expectedProcesses,proto3" json:"expected_processes,omitempty"`
	Now               int64      `protobuf:"varint,4,opt,name=now,proto3" json:"now,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateBarrierRequest) Descriptor deprecated 

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

Deprecated: Use UpdateBarrierRequest.ProtoReflect.Descriptor instead.

func (*UpdateBarrierRequest) GetBarrierId 

func (x *UpdateBarrierRequest) GetBarrierId() *BarrierId

func (*UpdateBarrierRequest) GetDescription 

func (x *UpdateBarrierRequest) GetDescription() string

func (*UpdateBarrierRequest) GetExpectedProcesses 

func (x *UpdateBarrierRequest) GetExpectedProcesses() uint64

func (*UpdateBarrierRequest) GetNow 

func (x *UpdateBarrierRequest) GetNow() int64

func (*UpdateBarrierRequest) ProtoMessage 

func (*UpdateBarrierRequest) ProtoMessage()

func (*UpdateBarrierRequest) ProtoReflect 

func (x *UpdateBarrierRequest) ProtoReflect() protoreflect.Message

func (*UpdateBarrierRequest) Reset 

func (x *UpdateBarrierRequest) Reset()

func (*UpdateBarrierRequest) String 

func (x *UpdateBarrierRequest) String() string

type UpdateBarrierResponse 

type UpdateBarrierResponse struct {
	Barrier *Barrier `protobuf:"bytes,1,opt,name=barrier,proto3" json:"barrier,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateBarrierResponse) Descriptor deprecated 

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

Deprecated: Use UpdateBarrierResponse.ProtoReflect.Descriptor instead.

func (*UpdateBarrierResponse) GetBarrier 

func (x *UpdateBarrierResponse) GetBarrier() *Barrier

func (*UpdateBarrierResponse) ProtoMessage 

func (*UpdateBarrierResponse) ProtoMessage()

func (*UpdateBarrierResponse) ProtoReflect 

func (x *UpdateBarrierResponse) ProtoReflect() protoreflect.Message

func (*UpdateBarrierResponse) Reset 

func (x *UpdateBarrierResponse) Reset()

func (*UpdateBarrierResponse) String 

func (x *UpdateBarrierResponse) String() string

type UpdateNamespaceRequest 

type UpdateNamespaceRequest struct {
	NamespaceId *NamespaceId `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	Description string       `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Now         int64        `protobuf:"varint,3,opt,name=now,proto3" json:"now,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateNamespaceRequest) Descriptor deprecated 

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

Deprecated: Use UpdateNamespaceRequest.ProtoReflect.Descriptor instead.

func (*UpdateNamespaceRequest) GetDescription 

func (x *UpdateNamespaceRequest) GetDescription() string

func (*UpdateNamespaceRequest) GetNamespaceId 

func (x *UpdateNamespaceRequest) GetNamespaceId() *NamespaceId

func (*UpdateNamespaceRequest) GetNow 

func (x *UpdateNamespaceRequest) GetNow() int64

func (*UpdateNamespaceRequest) ProtoMessage 

func (*UpdateNamespaceRequest) ProtoMessage()

func (*UpdateNamespaceRequest) ProtoReflect 

func (x *UpdateNamespaceRequest) ProtoReflect() protoreflect.Message

func (*UpdateNamespaceRequest) Reset 

func (x *UpdateNamespaceRequest) Reset()

func (*UpdateNamespaceRequest) String 

func (x *UpdateNamespaceRequest) String() string

type UpdateNamespaceResponse 

type UpdateNamespaceResponse struct {
	Namespace *Namespace `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateNamespaceResponse) Descriptor deprecated 

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

Deprecated: Use UpdateNamespaceResponse.ProtoReflect.Descriptor instead.

func (*UpdateNamespaceResponse) GetNamespace 

func (x *UpdateNamespaceResponse) GetNamespace() *Namespace

func (*UpdateNamespaceResponse) ProtoMessage 

func (*UpdateNamespaceResponse) ProtoMessage()

func (*UpdateNamespaceResponse) ProtoReflect 

func (x *UpdateNamespaceResponse) ProtoReflect() protoreflect.Message

func (*UpdateNamespaceResponse) Reset 

func (x *UpdateNamespaceResponse) Reset()

func (*UpdateNamespaceResponse) String 

func (x *UpdateNamespaceResponse) String() string

type UpdateSemaphoreRequest 

type UpdateSemaphoreRequest struct {
	NamespaceId   *NamespaceId `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	SemaphoreName string       `protobuf:"bytes,2,opt,name=semaphore_name,json=semaphoreName,proto3" json:"semaphore_name,omitempty"`
	Description   string       `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	Permits       uint64       `protobuf:"varint,4,opt,name=permits,proto3" json:"permits,omitempty"`
	Now           int64        `protobuf:"varint,5,opt,name=now,proto3" json:"now,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateSemaphoreRequest) Descriptor deprecated 

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

Deprecated: Use UpdateSemaphoreRequest.ProtoReflect.Descriptor instead.

func (*UpdateSemaphoreRequest) GetDescription 

func (x *UpdateSemaphoreRequest) GetDescription() string

func (*UpdateSemaphoreRequest) GetNamespaceId 

func (x *UpdateSemaphoreRequest) GetNamespaceId() *NamespaceId

func (*UpdateSemaphoreRequest) GetNow 

func (x *UpdateSemaphoreRequest) GetNow() int64

func (*UpdateSemaphoreRequest) GetPermits 

func (x *UpdateSemaphoreRequest) GetPermits() uint64

func (*UpdateSemaphoreRequest) GetSemaphoreName 

func (x *UpdateSemaphoreRequest) GetSemaphoreName() string

func (*UpdateSemaphoreRequest) ProtoMessage 

func (*UpdateSemaphoreRequest) ProtoMessage()

func (*UpdateSemaphoreRequest) ProtoReflect 

func (x *UpdateSemaphoreRequest) ProtoReflect() protoreflect.Message

func (*UpdateSemaphoreRequest) Reset 

func (x *UpdateSemaphoreRequest) Reset()

func (*UpdateSemaphoreRequest) String 

func (x *UpdateSemaphoreRequest) String() string

type UpdateSemaphoreResponse 

type UpdateSemaphoreResponse struct {
	Semaphore *Semaphore `protobuf:"bytes,1,opt,name=semaphore,proto3" json:"semaphore,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateSemaphoreResponse) Descriptor deprecated 

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

Deprecated: Use UpdateSemaphoreResponse.ProtoReflect.Descriptor instead.

func (*UpdateSemaphoreResponse) GetSemaphore 

func (x *UpdateSemaphoreResponse) GetSemaphore() *Semaphore

func (*UpdateSemaphoreResponse) ProtoMessage 

func (*UpdateSemaphoreResponse) ProtoMessage()

func (*UpdateSemaphoreResponse) ProtoReflect 

func (x *UpdateSemaphoreResponse) ProtoReflect() protoreflect.Message

func (*UpdateSemaphoreResponse) Reset 

func (x *UpdateSemaphoreResponse) Reset()

func (*UpdateSemaphoreResponse) String 

func (x *UpdateSemaphoreResponse) String() string

type WaitAtBarrierRequest 

type WaitAtBarrierRequest struct {
	NamespaceId *NamespaceId `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	BarrierName string       `protobuf:"bytes,2,opt,name=barrier_name,json=barrierName,proto3" json:"barrier_name,omitempty"`
	ProcessId   string       `protobuf:"bytes,3,opt,name=process_id,json=processId,proto3" json:"process_id,omitempty"`
	Now         int64        `protobuf:"varint,4,opt,name=now,proto3" json:"now,omitempty"`
	// contains filtered or unexported fields
}

func (*WaitAtBarrierRequest) Descriptor deprecated 

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

Deprecated: Use WaitAtBarrierRequest.ProtoReflect.Descriptor instead.

func (*WaitAtBarrierRequest) GetBarrierName 

func (x *WaitAtBarrierRequest) GetBarrierName() string

func (*WaitAtBarrierRequest) GetNamespaceId 

func (x *WaitAtBarrierRequest) GetNamespaceId() *NamespaceId

func (*WaitAtBarrierRequest) GetNow 

func (x *WaitAtBarrierRequest) GetNow() int64

func (*WaitAtBarrierRequest) GetProcessId 

func (x *WaitAtBarrierRequest) GetProcessId() string

func (*WaitAtBarrierRequest) ProtoMessage 

func (*WaitAtBarrierRequest) ProtoMessage()

func (*WaitAtBarrierRequest) ProtoReflect 

func (x *WaitAtBarrierRequest) ProtoReflect() protoreflect.Message

func (*WaitAtBarrierRequest) Reset 

func (x *WaitAtBarrierRequest) Reset()

func (*WaitAtBarrierRequest) String 

func (x *WaitAtBarrierRequest) String() string

type WaitAtBarrierResponse 

type WaitAtBarrierResponse struct {
	Barrier *Barrier `protobuf:"bytes,1,opt,name=barrier,proto3" json:"barrier,omitempty"`
	// contains filtered or unexported fields
}

func (*WaitAtBarrierResponse) Descriptor deprecated 

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

Deprecated: Use WaitAtBarrierResponse.ProtoReflect.Descriptor instead.

func (*WaitAtBarrierResponse) GetBarrier 

func (x *WaitAtBarrierResponse) GetBarrier() *Barrier

func (*WaitAtBarrierResponse) ProtoMessage 

func (*WaitAtBarrierResponse) ProtoMessage()

func (*WaitAtBarrierResponse) ProtoReflect 

func (x *WaitAtBarrierResponse) ProtoReflect() protoreflect.Message

func (*WaitAtBarrierResponse) Reset 

func (x *WaitAtBarrierResponse) Reset()

func (*WaitAtBarrierResponse) String 

func (x *WaitAtBarrierResponse) String() string

type WaitGroup 

type WaitGroup struct {
	Id          *WaitGroupId `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name        string       `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Description string       `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	CreatedAt   int64        `protobuf:"varint,4,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt   int64        `protobuf:"varint,5,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	ExpiresAt   int64        `protobuf:"varint,6,opt,name=expires_at,json=expiresAt,proto3" json:"expires_at,omitempty"`
	Counter     uint64       `protobuf:"varint,7,opt,name=counter,proto3" json:"counter,omitempty"`
	Completed   uint64       `protobuf:"varint,8,opt,name=completed,proto3" json:"completed,omitempty"`
	// contains filtered or unexported fields
}

func (*WaitGroup) Descriptor deprecated 

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

Deprecated: Use WaitGroup.ProtoReflect.Descriptor instead.

func (*WaitGroup) GetCompleted 

func (x *WaitGroup) GetCompleted() uint64

func (*WaitGroup) GetCounter 

func (x *WaitGroup) GetCounter() uint64

func (*WaitGroup) GetCreatedAt 

func (x *WaitGroup) GetCreatedAt() int64

func (*WaitGroup) GetDescription 

func (x *WaitGroup) GetDescription() string

func (*WaitGroup) GetExpiresAt 

func (x *WaitGroup) GetExpiresAt() int64

func (*WaitGroup) GetId 

func (x *WaitGroup) GetId() *WaitGroupId

func (*WaitGroup) GetName 

func (x *WaitGroup) GetName() string

func (*WaitGroup) GetUpdatedAt 

func (x *WaitGroup) GetUpdatedAt() int64

func (*WaitGroup) MarshalBinary 

func (m *WaitGroup) MarshalBinary() (data []byte, err error)

func (*WaitGroup) ProtoMessage 

func (*WaitGroup) ProtoMessage()

func (*WaitGroup) ProtoReflect 

func (x *WaitGroup) ProtoReflect() protoreflect.Message

func (*WaitGroup) Reset 

func (x *WaitGroup) Reset()

func (*WaitGroup) String 

func (x *WaitGroup) String() string

func (*WaitGroup) UnmarshalBinary 

func (m *WaitGroup) UnmarshalBinary(data []byte) error

type WaitGroupId 

type WaitGroupId struct {
	AccountId   uint64 `protobuf:"varint,1,opt,name=account_id,json=accountId,proto3" json:"account_id,omitempty"`
	NamespaceId uint32 `protobuf:"varint,2,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	WaitGroupId uint64 `protobuf:"varint,3,opt,name=wait_group_id,json=waitGroupId,proto3" json:"wait_group_id,omitempty"`
	// contains filtered or unexported fields
}

func (*WaitGroupId) Descriptor deprecated 

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

Deprecated: Use WaitGroupId.ProtoReflect.Descriptor instead.

func (*WaitGroupId) GetAccountId 

func (x *WaitGroupId) GetAccountId() uint64

func (*WaitGroupId) GetNamespaceId 

func (x *WaitGroupId) GetNamespaceId() uint32

func (*WaitGroupId) GetWaitGroupId 

func (x *WaitGroupId) GetWaitGroupId() uint64

func (*WaitGroupId) ProtoMessage 

func (*WaitGroupId) ProtoMessage()

func (*WaitGroupId) ProtoReflect 

func (x *WaitGroupId) ProtoReflect() protoreflect.Message

func (*WaitGroupId) Reset 

func (x *WaitGroupId) Reset()

func (*WaitGroupId) String 

func (x *WaitGroupId) String() string

type WaitGroupJob 

type WaitGroupJob struct {
	Id          *WaitGroupJobId `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	CompletedAt int64           `protobuf:"varint,2,opt,name=completed_at,json=completedAt,proto3" json:"completed_at,omitempty"`
	// contains filtered or unexported fields
}

func (*WaitGroupJob) Descriptor deprecated 

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

Deprecated: Use WaitGroupJob.ProtoReflect.Descriptor instead.

func (*WaitGroupJob) GetCompletedAt 

func (x *WaitGroupJob) GetCompletedAt() int64

func (*WaitGroupJob) GetId 

func (x *WaitGroupJob) GetId() *WaitGroupJobId

func (*WaitGroupJob) MarshalBinary 

func (m *WaitGroupJob) MarshalBinary() (data []byte, err error)

func (*WaitGroupJob) ProtoMessage 

func (*WaitGroupJob) ProtoMessage()

func (*WaitGroupJob) ProtoReflect 

func (x *WaitGroupJob) ProtoReflect() protoreflect.Message

func (*WaitGroupJob) Reset 

func (x *WaitGroupJob) Reset()

func (*WaitGroupJob) String 

func (x *WaitGroupJob) String() string

func (*WaitGroupJob) UnmarshalBinary 

func (m *WaitGroupJob) UnmarshalBinary(data []byte) error

type WaitGroupJobId 

type WaitGroupJobId struct {
	AccountId   uint64 `protobuf:"varint,1,opt,name=account_id,json=accountId,proto3" json:"account_id,omitempty"`
	NamespaceId uint32 `protobuf:"varint,2,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	WaitGroupId uint64 `protobuf:"varint,3,opt,name=wait_group_id,json=waitGroupId,proto3" json:"wait_group_id,omitempty"`
	ProcessId   string `protobuf:"bytes,4,opt,name=process_id,json=processId,proto3" json:"process_id,omitempty"`
	// contains filtered or unexported fields
}

func (*WaitGroupJobId) Descriptor deprecated 

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

Deprecated: Use WaitGroupJobId.ProtoReflect.Descriptor instead.

func (*WaitGroupJobId) GetAccountId 

func (x *WaitGroupJobId) GetAccountId() uint64

func (*WaitGroupJobId) GetNamespaceId 

func (x *WaitGroupJobId) GetNamespaceId() uint32

func (*WaitGroupJobId) GetProcessId 

func (x *WaitGroupJobId) GetProcessId() string

func (*WaitGroupJobId) GetWaitGroupId 

func (x *WaitGroupJobId) GetWaitGroupId() uint64

func (*WaitGroupJobId) ProtoMessage 

func (*WaitGroupJobId) ProtoMessage()

func (*WaitGroupJobId) ProtoReflect 

func (x *WaitGroupJobId) ProtoReflect() protoreflect.Message

func (*WaitGroupJobId) Reset 

func (x *WaitGroupJobId) Reset()

func (*WaitGroupJobId) String 

func (x *WaitGroupJobId) String() string

type WaitGroupsCounter 

type WaitGroupsCounter struct {
	NamespaceId        *NamespaceId `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	NumberOfWaitGroups int64        `protobuf:"varint,2,opt,name=number_of_wait_groups,json=numberOfWaitGroups,proto3" json:"number_of_wait_groups,omitempty"`
	// contains filtered or unexported fields
}

func (*WaitGroupsCounter) Descriptor deprecated 

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

Deprecated: Use WaitGroupsCounter.ProtoReflect.Descriptor instead.

func (*WaitGroupsCounter) GetNamespaceId 

func (x *WaitGroupsCounter) GetNamespaceId() *NamespaceId

func (*WaitGroupsCounter) GetNumberOfWaitGroups 

func (x *WaitGroupsCounter) GetNumberOfWaitGroups() int64

func (*WaitGroupsCounter) MarshalBinary 

func (m *WaitGroupsCounter) MarshalBinary() (data []byte, err error)

func (*WaitGroupsCounter) ProtoMessage 

func (*WaitGroupsCounter) ProtoMessage()

func (*WaitGroupsCounter) ProtoReflect 

func (x *WaitGroupsCounter) ProtoReflect() protoreflect.Message

func (*WaitGroupsCounter) Reset 

func (x *WaitGroupsCounter) Reset()

func (*WaitGroupsCounter) String 

func (x *WaitGroupsCounter) String() string

func (*WaitGroupsCounter) UnmarshalBinary 

func (m *WaitGroupsCounter) UnmarshalBinary(data []byte) error

type WaitGroupsDeleteNamespaceRequest 

type WaitGroupsDeleteNamespaceRequest struct {
	RecordId    uint64       `protobuf:"varint,1,opt,name=record_id,json=recordId,proto3" json:"record_id,omitempty"`
	NamespaceId *NamespaceId `protobuf:"bytes,2,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	Now         int64        `protobuf:"varint,3,opt,name=now,proto3" json:"now,omitempty"`
	// contains filtered or unexported fields
}

func (*WaitGroupsDeleteNamespaceRequest) Descriptor deprecated 

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

Deprecated: Use WaitGroupsDeleteNamespaceRequest.ProtoReflect.Descriptor instead.

func (*WaitGroupsDeleteNamespaceRequest) GetNamespaceId 

func (x *WaitGroupsDeleteNamespaceRequest) GetNamespaceId() *NamespaceId

func (*WaitGroupsDeleteNamespaceRequest) GetNow 

func (x *WaitGroupsDeleteNamespaceRequest) GetNow() int64

func (*WaitGroupsDeleteNamespaceRequest) GetRecordId 

func (x *WaitGroupsDeleteNamespaceRequest) GetRecordId() uint64

func (*WaitGroupsDeleteNamespaceRequest) ProtoMessage 

func (*WaitGroupsDeleteNamespaceRequest) ProtoMessage()

func (*WaitGroupsDeleteNamespaceRequest) ProtoReflect 

func (x *WaitGroupsDeleteNamespaceRequest) ProtoReflect() protoreflect.Message

func (*WaitGroupsDeleteNamespaceRequest) Reset 

func (x *WaitGroupsDeleteNamespaceRequest) Reset()

func (*WaitGroupsDeleteNamespaceRequest) String 

func (x *WaitGroupsDeleteNamespaceRequest) String() string

type WaitGroupsDeleteNamespaceResponse 

type WaitGroupsDeleteNamespaceResponse struct {
	// contains filtered or unexported fields
}

func (*WaitGroupsDeleteNamespaceResponse) Descriptor deprecated 

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

Deprecated: Use WaitGroupsDeleteNamespaceResponse.ProtoReflect.Descriptor instead.

func (*WaitGroupsDeleteNamespaceResponse) ProtoMessage 

func (*WaitGroupsDeleteNamespaceResponse) ProtoMessage()

func (*WaitGroupsDeleteNamespaceResponse) ProtoReflect 

func (x *WaitGroupsDeleteNamespaceResponse) ProtoReflect() protoreflect.Message

func (*WaitGroupsDeleteNamespaceResponse) Reset 

func (x *WaitGroupsDeleteNamespaceResponse) Reset()

func (*WaitGroupsDeleteNamespaceResponse) String 

func (x *WaitGroupsDeleteNamespaceResponse) String() string

type WaitGroupsExpirationRecord 

type WaitGroupsExpirationRecord struct {
	WaitGroupId *WaitGroupId `protobuf:"bytes,1,opt,name=wait_group_id,json=waitGroupId,proto3" json:"wait_group_id,omitempty"`
	ExpiresAt   int64        `protobuf:"varint,2,opt,name=expires_at,json=expiresAt,proto3" json:"expires_at,omitempty"`
	// contains filtered or unexported fields
}

func (*WaitGroupsExpirationRecord) Descriptor deprecated 

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

Deprecated: Use WaitGroupsExpirationRecord.ProtoReflect.Descriptor instead.

func (*WaitGroupsExpirationRecord) GetExpiresAt 

func (x *WaitGroupsExpirationRecord) GetExpiresAt() int64

func (*WaitGroupsExpirationRecord) GetWaitGroupId 

func (x *WaitGroupsExpirationRecord) GetWaitGroupId() *WaitGroupId

func (*WaitGroupsExpirationRecord) MarshalBinary 

func (m *WaitGroupsExpirationRecord) MarshalBinary() (data []byte, err error)

func (*WaitGroupsExpirationRecord) ProtoMessage 

func (*WaitGroupsExpirationRecord) ProtoMessage()

func (*WaitGroupsExpirationRecord) ProtoReflect 

func (x *WaitGroupsExpirationRecord) ProtoReflect() protoreflect.Message

func (*WaitGroupsExpirationRecord) Reset 

func (x *WaitGroupsExpirationRecord) Reset()

func (*WaitGroupsExpirationRecord) String 

func (x *WaitGroupsExpirationRecord) String() string

func (*WaitGroupsExpirationRecord) UnmarshalBinary 

func (m *WaitGroupsExpirationRecord) UnmarshalBinary(data []byte) error

type WaitGroupsGarbageCollectionRecord 

type WaitGroupsGarbageCollectionRecord struct {
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Types that are valid to be assigned to Record:
	//
	//	*WaitGroupsGarbageCollectionRecord_NamespaceId
	//	*WaitGroupsGarbageCollectionRecord_WaitGroupId
	Record isWaitGroupsGarbageCollectionRecord_Record `protobuf_oneof:"record"`
	// contains filtered or unexported fields
}

func (*WaitGroupsGarbageCollectionRecord) Descriptor deprecated 

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

Deprecated: Use WaitGroupsGarbageCollectionRecord.ProtoReflect.Descriptor instead.

func (*WaitGroupsGarbageCollectionRecord) GetId 

func (x *WaitGroupsGarbageCollectionRecord) GetId() uint64

func (*WaitGroupsGarbageCollectionRecord) GetNamespaceId 

func (x *WaitGroupsGarbageCollectionRecord) GetNamespaceId() *NamespaceId

func (*WaitGroupsGarbageCollectionRecord) GetRecord 

func (x *WaitGroupsGarbageCollectionRecord) GetRecord() isWaitGroupsGarbageCollectionRecord_Record

func (*WaitGroupsGarbageCollectionRecord) GetWaitGroupId 

func (x *WaitGroupsGarbageCollectionRecord) GetWaitGroupId() *WaitGroupId

func (*WaitGroupsGarbageCollectionRecord) MarshalBinary 

func (m *WaitGroupsGarbageCollectionRecord) MarshalBinary() (data []byte, err error)

func (*WaitGroupsGarbageCollectionRecord) ProtoMessage 

func (*WaitGroupsGarbageCollectionRecord) ProtoMessage()

func (*WaitGroupsGarbageCollectionRecord) ProtoReflect 

func (x *WaitGroupsGarbageCollectionRecord) ProtoReflect() protoreflect.Message

func (*WaitGroupsGarbageCollectionRecord) Reset 

func (x *WaitGroupsGarbageCollectionRecord) Reset()

func (*WaitGroupsGarbageCollectionRecord) String 

func (x *WaitGroupsGarbageCollectionRecord) String() string

func (*WaitGroupsGarbageCollectionRecord) UnmarshalBinary 

func (m *WaitGroupsGarbageCollectionRecord) UnmarshalBinary(data []byte) error

type WaitGroupsGarbageCollectionRecord_NamespaceId 

type WaitGroupsGarbageCollectionRecord_NamespaceId struct {
	NamespaceId *NamespaceId `protobuf:"bytes,2,opt,name=namespace_id,json=namespaceId,proto3,oneof"`
}

type WaitGroupsGarbageCollectionRecord_WaitGroupId 

type WaitGroupsGarbageCollectionRecord_WaitGroupId struct {
	WaitGroupId *WaitGroupId `protobuf:"bytes,3,opt,name=wait_group_id,json=waitGroupId,proto3,oneof"`
}

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.