transaction

Documentation

Index

• func NewServer(txMgr *transactions.Manager) gitalypb.RefTransactionServer
• type Server
  • func (s *Server) StopTransaction(ctx context.Context, in *gitalypb.StopTransactionRequest) (*gitalypb.StopTransactionResponse, error)
  • func (s *Server) VoteTransaction(ctx context.Context, in *gitalypb.VoteTransactionRequest) (*gitalypb.VoteTransactionResponse, error)

Functions

func NewServer

func NewServer(txMgr *transactions.Manager) gitalypb.RefTransactionServer

Types

type Server

type Server struct {
	gitalypb.UnimplementedRefTransactionServer
	// contains filtered or unexported fields
}

func (*Server) StopTransaction

func (s *Server) StopTransaction(ctx context.Context, in *gitalypb.StopTransactionRequest) (*gitalypb.StopTransactionResponse, error)

StopTransaction is called by a client who wants to gracefully stop a transaction. All voters waiting for quorum will be stopped and new votes will not get accepted anymore. It is fine to call this RPC multiple times on the same transaction.

func (*Server) VoteTransaction

func (s *Server) VoteTransaction(ctx context.Context, in *gitalypb.VoteTransactionRequest) (*gitalypb.VoteTransactionResponse, error)

VoteTransaction is called by a client who's casting a vote on a reference transaction, blocking until a vote across all participating nodes has been completed.