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, 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) 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
- func (n *Node) GetKeygroupReplica(kgname string, expectError 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)
- 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) 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) GetKeygroupReplica ¶
GetKeygroupReplica calls the GetKeygroupReplica 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) RemoveUser ¶
RemoveUser calls the RemoveUser endpoint of the GRPC interface.