server

Documentation

Index

• Constants
• type CallbackMessageQueue
  • func NewCallbackMessageQueue() *CallbackMessageQueue
  • func (p *CallbackMessageQueue) Dequeue() *apis.BranchMessage
  • func (p *CallbackMessageQueue) Enqueue(msg *apis.BranchMessage)
• type GlobalSessionLocker
• type TransactionCoordinator
  • func NewTransactionCoordinator(conf *config.Configuration) *TransactionCoordinator
  • func (tc *TransactionCoordinator) Begin(ctx context.Context, request *apis.GlobalBeginRequest) (*apis.GlobalBeginResponse, error)
  • func (tc *TransactionCoordinator) BranchCommunicate(stream apis.ResourceManagerService_BranchCommunicateServer) error
  • func (tc *TransactionCoordinator) BranchRegister(ctx context.Context, request *apis.BranchRegisterRequest) (*apis.BranchRegisterResponse, error)
  • func (tc *TransactionCoordinator) BranchReport(ctx context.Context, request *apis.BranchReportRequest) (*apis.BranchReportResponse, error)
  • func (tc *TransactionCoordinator) Commit(ctx context.Context, request *apis.GlobalCommitRequest) (*apis.GlobalCommitResponse, error)
  • func (tc *TransactionCoordinator) GetStatus(ctx context.Context, request *apis.GlobalStatusRequest) (*apis.GlobalStatusResponse, error)
  • func (tc *TransactionCoordinator) GlobalReport(ctx context.Context, request *apis.GlobalReportRequest) (*apis.GlobalReportResponse, error)
  • func (tc *TransactionCoordinator) LockQuery(ctx context.Context, request *apis.GlobalLockQueryRequest) (*apis.GlobalLockQueryResponse, error)
  • func (tc *TransactionCoordinator) Rollback(ctx context.Context, request *apis.GlobalRollbackRequest) (*apis.GlobalRollbackResponse, error)
• type UnimplementedGlobalSessionLocker
  • func (locker *UnimplementedGlobalSessionLocker) TryLock(session *apis.GlobalSession, timeout time.Duration) (bool, error)
  • func (locker *UnimplementedGlobalSessionLocker) Unlock(session *apis.GlobalSession)

Constants

const AlwaysRetryBoundary = 0

Types

type CallbackMessageQueue

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

func NewCallbackMessageQueue

func NewCallbackMessageQueue() *CallbackMessageQueue

func (*CallbackMessageQueue) Dequeue

func (p *CallbackMessageQueue) Dequeue() *apis.BranchMessage

func (*CallbackMessageQueue) Enqueue

func (p *CallbackMessageQueue) Enqueue(msg *apis.BranchMessage)

type GlobalSessionLocker

type GlobalSessionLocker interface {
	TryLock(session *apis.GlobalSession, timeout time.Duration) (bool, error)

	Unlock(session *apis.GlobalSession)
}

type TransactionCoordinator

type TransactionCoordinator struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewTransactionCoordinator

func NewTransactionCoordinator(conf *config.Configuration) *TransactionCoordinator

func (*TransactionCoordinator) Begin

func (tc *TransactionCoordinator) Begin(ctx context.Context, request *apis.GlobalBeginRequest) (*apis.GlobalBeginResponse, error)

func (*TransactionCoordinator) BranchCommunicate

func (tc *TransactionCoordinator) BranchCommunicate(stream apis.ResourceManagerService_BranchCommunicateServer) error

func (*TransactionCoordinator) BranchRegister

func (tc *TransactionCoordinator) BranchRegister(ctx context.Context, request *apis.BranchRegisterRequest) (*apis.BranchRegisterResponse, error)

func (*TransactionCoordinator) BranchReport

func (tc *TransactionCoordinator) BranchReport(ctx context.Context, request *apis.BranchReportRequest) (*apis.BranchReportResponse, error)

func (*TransactionCoordinator) Commit

func (tc *TransactionCoordinator) Commit(ctx context.Context, request *apis.GlobalCommitRequest) (*apis.GlobalCommitResponse, error)

func (*TransactionCoordinator) GetStatus

func (tc *TransactionCoordinator) GetStatus(ctx context.Context, request *apis.GlobalStatusRequest) (*apis.GlobalStatusResponse, error)

func (*TransactionCoordinator) GlobalReport

func (tc *TransactionCoordinator) GlobalReport(ctx context.Context, request *apis.GlobalReportRequest) (*apis.GlobalReportResponse, error)

func (*TransactionCoordinator) LockQuery

func (tc *TransactionCoordinator) LockQuery(ctx context.Context, request *apis.GlobalLockQueryRequest) (*apis.GlobalLockQueryResponse, error)

func (*TransactionCoordinator) Rollback

func (tc *TransactionCoordinator) Rollback(ctx context.Context, request *apis.GlobalRollbackRequest) (*apis.GlobalRollbackResponse, error)

type UnimplementedGlobalSessionLocker

type UnimplementedGlobalSessionLocker struct {
}

func (*UnimplementedGlobalSessionLocker) TryLock

func (locker *UnimplementedGlobalSessionLocker) TryLock(session *apis.GlobalSession, timeout time.Duration) (bool, error)

func (*UnimplementedGlobalSessionLocker) Unlock

func (locker *UnimplementedGlobalSessionLocker) Unlock(session *apis.GlobalSession)