Documentation
¶
Index ¶
- type Node
- func (n *Node) AddKeygroupReplica(kgname, replicaNodeID string, expiry int, expectError bool)
- func (n *Node) AddKeygroupTrigger(kgname, triggerNodeID, triggerNodeHost string, expectError bool)
- func (n *Node) AddUser(user string, kgname string, role string, expectError bool)
- func (n *Node) AppendItem(kgname string, id uint64, data string, expectError bool) string
- func (n *Node) Close()
- func (n *Node) CreateKeygroup(kgname string, mutable bool, expiry int, expectError bool)
- func (n *Node) DeleteItem(kgname, item string, expectError bool)
- func (n *Node) DeleteItemVersion(kgname, item string, version vclock.VClock, expectError bool) vclock.VClock
- func (n *Node) DeleteKeygroup(kgname string, expectError bool)
- func (n *Node) DeleteKeygroupReplica(kgname, replicaNodeID string, expectError bool)
- func (n *Node) DeleteKeygroupTrigger(kgname, triggerNodeID string, expectError bool)
- func (n *Node) GetAllReplica(expectError bool) map[string]string
- func (n *Node) GetItem(kgname, item string, expectError bool) ([]string, []vclock.VClock)
- func (n *Node) GetKeygroupInfo(kgname string, expectError bool) (bool, map[string]int)
- func (n *Node) GetKeygroupTriggers(kgname string, expectError bool) []*client.Trigger
- func (n *Node) GetReplica(nodeID string, expectError bool) (string, string)
- func (n *Node) PutItem(kgname, item string, data string, expectError bool) vclock.VClock
- func (n *Node) PutItemVersion(kgname, item string, data string, version vclock.VClock, expectError bool) vclock.VClock
- func (n *Node) RemoveUser(user string, kgname string, role string, expectError bool)
- func (n *Node) ScanItems(kgname, item string, count uint64, expectError bool) map[string]string
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Node ¶
type Node struct {
Errors int
ID string
Client client.ClientClient
Addr string
// contains filtered or unexported fields
}
Node represents the API to a single FReD Node
func NewNode ¶
func NewNode(addr string, port int, id string, certFile string, keyFile string, caFile string) *Node
NewNode creates a new Node that represents a connection to a single fred instance
func (*Node) AddKeygroupReplica ¶
AddKeygroupReplica calls the AddKeygroupReplica endpoint of the GRPC interface.
func (*Node) AddKeygroupTrigger ¶
AddKeygroupTrigger calls the AddKeygroupTrigger endpoint of the GRPC interface.
func (*Node) AppendItem ¶
AppendItem calls the AppendItem endpoint of the GRPC interface.
func (*Node) CreateKeygroup ¶
CreateKeygroup calls the CreateKeygroup endpoint of the GRPC interface.
func (*Node) DeleteItem ¶
DeleteItem calls the DeleteItem endpoint of the GRPC interface.
func (*Node) DeleteItemVersion ¶ added in v0.2.1
func (n *Node) DeleteItemVersion(kgname, item string, version vclock.VClock, expectError bool) vclock.VClock
DeleteItemVersion calls the DeleteItem endpoint of the GRPC interface with a version.
func (*Node) DeleteKeygroup ¶
DeleteKeygroup calls the DeleteKeygroup endpoint of the GRPC interface.
func (*Node) DeleteKeygroupReplica ¶
DeleteKeygroupReplica calls the DeleteKeygroupReplica endpoint of the GRPC interface.
func (*Node) DeleteKeygroupTrigger ¶
DeleteKeygroupTrigger calls the DeleteKeygroupTrigger endpoint of the GRPC interface.
func (*Node) GetAllReplica ¶
GetAllReplica calls the GetAllReplica endpoint of the GRPC interface.
func (*Node) GetKeygroupInfo ¶ added in v0.2.2
GetKeygroupInfo calls the GetKeygroupInfo endpoint of the GRPC interface.
func (*Node) GetKeygroupTriggers ¶
GetKeygroupTriggers calls the GetKeygroupTriggers endpoint of the GRPC interface.
func (*Node) GetReplica ¶
GetReplica calls the GetReplica endpoint of the GRPC interface.
func (*Node) PutItemVersion ¶ added in v0.2.1
func (n *Node) PutItemVersion(kgname, item string, data string, version vclock.VClock, expectError bool) vclock.VClock
PutItemVersion calls the PutItem endpoint of the GRPC interface with a version.
func (*Node) RemoveUser ¶
RemoveUser calls the RemoveUser endpoint of the GRPC interface.
Source Files