saga

Documentation

Index

• Variables
• func StartRm(listen string, db *gorm.DB, protocol string) error
• type BankAccount
  • func (*BankAccount) TableName() string
• type BankAccountRecord
  • func (ba *BankAccountRecord) ToPb() *pb.SagaRequest
• type SagaRmBankGrpcService
  • func NewSagaRmBankGrpcService(listen string, db *gorm.DB) *SagaRmBankGrpcService
  • func (rm *SagaRmBankGrpcService) In(ctx context.Context, in *pb.SagaRequest) (*pb.SagaResponse, error)
  • func (rm *SagaRmBankGrpcService) Out(ctx context.Context, in *pb.SagaRequest) (*pb.SagaResponse, error)
  • func (rm *SagaRmBankGrpcService) Start() error
• type SagaRmBankService
  • func NewSagaRmBankService(listen string, db *gorm.DB) *SagaRmBankService
  • func (rm *SagaRmBankService) Start() error

Variables

var (
	SagaRmBankServiceBasePath = "/paywage/saga"
)

Functions

func StartRm

func StartRm(listen string, db *gorm.DB, protocol string) error

Types

type BankAccount

type BankAccount struct {
	Id      int
	Balance int
	Freeze  int `gorm:"balance_freeze"`
}

func (*BankAccount) TableName

func (*BankAccount) TableName() string

type BankAccountRecord

type BankAccountRecord struct {
	UserID  int
	Account int
	Fail    bool
}

func (*BankAccountRecord) ToPb

func (ba *BankAccountRecord) ToPb() *pb.SagaRequest

type SagaRmBankGrpcService

type SagaRmBankGrpcService struct {
	pb.UnsafeSagaBankServiceServer
	// contains filtered or unexported fields
}

func NewSagaRmBankGrpcService

func NewSagaRmBankGrpcService(listen string, db *gorm.DB) *SagaRmBankGrpcService

func (*SagaRmBankGrpcService) In

func (rm *SagaRmBankGrpcService) In(ctx context.Context, in *pb.SagaRequest) (*pb.SagaResponse, error)

func (*SagaRmBankGrpcService) Out

func (rm *SagaRmBankGrpcService) Out(ctx context.Context, in *pb.SagaRequest) (*pb.SagaResponse, error)

func (*SagaRmBankGrpcService) Start

func (rm *SagaRmBankGrpcService) Start() error

type SagaRmBankService

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

func NewSagaRmBankService

func NewSagaRmBankService(listen string, db *gorm.DB) *SagaRmBankService

func (*SagaRmBankService) Start

func (rm *SagaRmBankService) Start() error