Documentation
¶
Index ¶
- Constants
- Variables
- type AbortRequest
- type Client
- func (c *Client) Abort(dsName string, keyList []string, txnId string) error
- func (c *Client) Commit(dsName string, infoList []txn.CommitInfo) error
- func (c *Client) GetServerAddr() string
- func (c *Client) Prepare(dsName string, itemList []txn.DataItem, startTime time.Time, ...) (map[string]string, error)
- func (c *Client) Read(dsName string, key string, ts time.Time, cfg txn.RecordConfig) (txn.DataItem, txn.RemoteDataStrategy, error)
- type CommitRequest
- type Committer
- type PrepareRequest
- type ReadRequest
- type ReadResponse
- type Reader
- type Response
Constants ¶
View Source
const (
ReadFailed = "read failed due to unknown txn status"
)
Variables ¶
View Source
var HttpClient = &http.Client{ Transport: &http.Transport{ MaxIdleConns: 6000, MaxIdleConnsPerHost: 1000, MaxConnsPerHost: 1000, }, }
Functions ¶
This section is empty.
Types ¶
type AbortRequest ¶
type Client ¶
type Client struct {
ServerAddrList []string
// contains filtered or unexported fields
}
func (*Client) GetServerAddr ¶
type CommitRequest ¶
type CommitRequest struct {
DsName string
List []txn.CommitInfo
}
type Committer ¶
type Committer struct {
// contains filtered or unexported fields
}
func NewCommitter ¶
func NewCommitter(connMap map[string]txn.Connector, se serializer.Serializer, itemFactory txn.DataItemFactory) *Committer
type PrepareRequest ¶
type PrepareRequest struct {
DsName string
ValidationMap map[string]txn.PredicateInfo
ItemType txn.ItemType
ItemList []txn.DataItem
StartTime time.Time
CommitTime time.Time
Config txn.RecordConfig
}
func (*PrepareRequest) UnmarshalJSON ¶
func (p *PrepareRequest) UnmarshalJSON(data []byte) error
type ReadRequest ¶
type ReadResponse ¶
type ReadResponse struct {
Status string
ErrMsg string
DataStrategy txn.RemoteDataStrategy
ItemType txn.ItemType
Data txn.DataItem
}
func (*ReadResponse) UnmarshalJSON ¶
func (r *ReadResponse) UnmarshalJSON(data []byte) error
type Reader ¶
type Reader struct {
// contains filtered or unexported fields
}
func NewReader ¶
func NewReader(connMap map[string]txn.Connector, itemFactory txn.DataItemFactory, se serializer.Serializer) *Reader
Click to show internal directories.
Click to hide internal directories.