transaction

Documentation

Index

• Constants
• type Service
  • func NewService(db *gorm.DB) *Service
  • func (srv Service) AbnormalStopTransaction(ctx context.Context, req *rpc.AbnormalStopTransactionReq) (*rpc.AbnormalStopTransactionResp, error)
  • func (srv Service) AbortTransaction(ctx context.Context, req *rpc.AbortTransactionReq) (*rpc.AbortTransactionResp, error)
  • func (srv Service) CreateTransaction(ctx context.Context, req *rpc.CreateTransactionReq) (*rpc.CreateTransactionResp, error)
  • func (srv Service) GetOngoingTransaction(ctx context.Context, req *rpc.GetOngoingTransactionReq) (*rpc.GetOngoingTransactionResp, error)
  • func (srv Service) StartTransaction(ctx context.Context, req *rpc.StartTransactionReq) (*rpc.StartTransactionResp, error)
  • func (srv Service) StopTransaction(ctx context.Context, req *rpc.StopTransactionReq) (*rpc.StopTransactionResp, error)

Constants

const RFC3339Milli = "2006-01-02T15:04:05.000Z07:00"

Types

type Service

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

func NewService

func NewService(db *gorm.DB) *Service

func (Service) AbnormalStopTransaction

func (srv Service) AbnormalStopTransaction(ctx context.Context, req *rpc.AbnormalStopTransactionReq) (*rpc.AbnormalStopTransactionResp, error)

func (Service) AbortTransaction

func (srv Service) AbortTransaction(ctx context.Context, req *rpc.AbortTransactionReq) (*rpc.AbortTransactionResp, error)

func (Service) CreateTransaction

func (srv Service) CreateTransaction(ctx context.Context, req *rpc.CreateTransactionReq) (*rpc.CreateTransactionResp, error)

func (Service) GetOngoingTransaction

func (srv Service) GetOngoingTransaction(ctx context.Context, req *rpc.GetOngoingTransactionReq) (*rpc.GetOngoingTransactionResp, error)

func (Service) StartTransaction

func (srv Service) StartTransaction(ctx context.Context, req *rpc.StartTransactionReq) (*rpc.StartTransactionResp, error)

func (Service) StopTransaction

func (srv Service) StopTransaction(ctx context.Context, req *rpc.StopTransactionReq) (*rpc.StopTransactionResp, error)