grpc

Documentation

Overview

Package grpc implements transaction protocols using gRPC

Index

• type ManagerClient
  • func NewManagerClient(grpcClient pb.ManagerServiceClient) *ManagerClient
  • func (r *ManagerClient) Begin(ctx context.Context, votes tcommit.Votes, meta tcommit.Meta) error
  • func (r *ManagerClient) Finish(ctx context.Context, nodeID tcommit.NodeID, meta tcommit.Meta) error
• type ResourceClient
  • func NewResourceClient(grpcClient pb.ResourceServiceClient) *ResourceClient
  • func (r *ResourceClient) Abort(ctx context.Context) error
  • func (r *ResourceClient) Commit(ctx context.Context) error

Types

type ManagerClient

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

ManagerClient implemets tcommit.Manager interface. It is assumed to be a part of the resource manager for remote procedure calls.

func NewManagerClient

func NewManagerClient(grpcClient pb.ManagerServiceClient) *ManagerClient

NewManagerClient with a given gRPC client.

func (*ManagerClient) Begin

func (r *ManagerClient) Begin(ctx context.Context, votes tcommit.Votes,
	meta tcommit.Meta) error

Begin transaction RPC

func (*ManagerClient) Finish

func (r *ManagerClient) Finish(ctx context.Context, nodeID tcommit.NodeID,
	meta tcommit.Meta) error

Finish transaction RPC

type ResourceClient

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

ResourceClient implements tcommit.Resource interface. It is assumed to be a part of the transaction manager for remote procedure calls.

func NewResourceClient

func NewResourceClient(grpcClient pb.ResourceServiceClient) *ResourceClient

NewResourceClient with a given gRPC client

func (*ResourceClient) Abort

func (r *ResourceClient) Abort(ctx context.Context) error

Abort transaction RPC

func (*ResourceClient) Commit

func (r *ResourceClient) Commit(ctx context.Context) error

Commit transaction RPC