Documentation ¶
Index ¶
- type CommitClient
- func (client *CommitClient) Commit(ctx context.Context, req *proto.CommitRequest) (*proto.Response, error)
- func (client *CommitClient) Get(ctx context.Context, key string) (*proto.Value, error)
- func (client *CommitClient) NodeInfo(ctx context.Context) (*proto.Info, error)
- func (client *CommitClient) Precommit(ctx context.Context, req *proto.PrecommitRequest) (*proto.Response, error)
- func (client *CommitClient) Propose(ctx context.Context, req *proto.ProposeRequest) (*proto.Response, error)
- func (client *CommitClient) Put(ctx context.Context, key string, value []byte) (*proto.Response, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CommitClient ¶
type CommitClient struct { Connection proto.CommitClient Tracer *zipkin.Tracer }
func New ¶
func New(addr string, tracer *zipkin.Tracer) (*CommitClient, error)
New creates instance of peer client. 'addr' is a coordinator network address (host + port).
func (*CommitClient) Commit ¶
func (client *CommitClient) Commit(ctx context.Context, req *proto.CommitRequest) (*proto.Response, error)
func (*CommitClient) Precommit ¶
func (client *CommitClient) Precommit(ctx context.Context, req *proto.PrecommitRequest) (*proto.Response, error)
func (*CommitClient) Propose ¶
func (client *CommitClient) Propose(ctx context.Context, req *proto.ProposeRequest) (*proto.Response, error)
Click to show internal directories.
Click to hide internal directories.