grpcapi

Documentation

Index

• Constants
• func CreateServer(grpcServer *grpc.Server, dbConn *sqlx.DB, newTxIDCh, cancelTxIDCh chan string) (*grpc.Server, error)
• type DistributedTxService
  • func (dt *DistributedTxService) Commit(ctx context.Context, req *distributedTxPb.TxToCommit) (*distributedTxPb.TxResponse, error)
  • func (dt *DistributedTxService) Rollback(ctx context.Context, req *distributedTxPb.TxToRollback) (*distributedTxPb.TxResponse, error)
• type UsersService
  • func (us *UsersService) CreateUser(ctx context.Context, newUser *usersPb.NewUser) (*usersPb.CreatedUser, error)

Constants

const TracerNameUsersManager = "users-manager-grpcapi"

Functions

func CreateServer

func CreateServer(grpcServer *grpc.Server, dbConn *sqlx.DB,
	newTxIDCh, cancelTxIDCh chan string,
) (*grpc.Server, error)

Types

type DistributedTxService

type DistributedTxService struct {
	distributedTxPb.UnimplementedDistributedTxServiceServer
	// contains filtered or unexported fields
}

func (*DistributedTxService) Commit

func (dt *DistributedTxService) Commit(ctx context.Context, req *distributedTxPb.TxToCommit) (
	*distributedTxPb.TxResponse, error,
)

func (*DistributedTxService) Rollback

func (dt *DistributedTxService) Rollback(ctx context.Context, req *distributedTxPb.TxToRollback) (
	*distributedTxPb.TxResponse, error,
)

type UsersService

type UsersService struct {
	usersPb.UnimplementedUsersServer
	// contains filtered or unexported fields
}

func (*UsersService) CreateUser

func (us *UsersService) CreateUser(ctx context.Context, newUser *usersPb.NewUser) (*usersPb.CreatedUser, error)