Documentation ¶
Index ¶
- func StartAPIProxy(p *Proxy, port int, cert string, key string, caCert string) (*grpc.Server, error)
- func StartPeeringProxy(p *Proxy, port int, certFile string, keyFile string, caFile string) (*grpc.Server, error)
- type APIProxy
- func (a *APIProxy) AddReplica(ctx context.Context, req *client.AddReplicaRequest) (*client.Empty, error)
- func (a *APIProxy) AddTrigger(ctx context.Context, req *client.AddTriggerRequest) (*client.Empty, error)
- func (a *APIProxy) AddUser(ctx context.Context, req *client.AddUserRequest) (*client.Empty, error)
- func (a *APIProxy) Append(ctx context.Context, req *client.AppendRequest) (*client.AppendResponse, error)
- func (a *APIProxy) CreateKeygroup(ctx context.Context, req *client.CreateKeygroupRequest) (*client.Empty, error)
- func (a *APIProxy) Delete(ctx context.Context, req *client.DeleteRequest) (*client.DeleteResponse, error)
- func (a *APIProxy) DeleteKeygroup(ctx context.Context, req *client.DeleteKeygroupRequest) (*client.Empty, error)
- func (a *APIProxy) GetAllReplica(ctx context.Context, req *client.Empty) (*client.GetAllReplicaResponse, error)
- func (a *APIProxy) GetKeygroupInfo(ctx context.Context, req *client.GetKeygroupInfoRequest) (*client.GetKeygroupInfoResponse, error)
- func (a *APIProxy) GetKeygroupTriggers(ctx context.Context, req *client.GetKeygroupTriggerRequest) (*client.GetKeygroupTriggerResponse, error)
- func (a *APIProxy) GetReplica(ctx context.Context, req *client.GetReplicaRequest) (*client.GetReplicaResponse, error)
- func (a *APIProxy) Read(ctx context.Context, req *client.ReadRequest) (*client.ReadResponse, error)
- func (a *APIProxy) RemoveReplica(ctx context.Context, req *client.RemoveReplicaRequest) (*client.Empty, error)
- func (a *APIProxy) RemoveTrigger(ctx context.Context, req *client.RemoveTriggerRequest) (*client.Empty, error)
- func (a *APIProxy) RemoveUser(ctx context.Context, req *client.RemoveUserRequest) (*client.Empty, error)
- func (a *APIProxy) Scan(ctx context.Context, req *client.ScanRequest) (*client.ScanResponse, error)
- func (a *APIProxy) Update(ctx context.Context, req *client.UpdateRequest) (*client.UpdateResponse, error)
- type PeeringProxy
- func (p *PeeringProxy) AppendItem(ctx context.Context, req *peering.AppendItemRequest) (*peering.Empty, error)
- func (p *PeeringProxy) CreateKeygroup(ctx context.Context, req *peering.CreateKeygroupRequest) (*peering.Empty, error)
- func (p *PeeringProxy) DeleteKeygroup(ctx context.Context, req *peering.DeleteKeygroupRequest) (*peering.Empty, error)
- func (p *PeeringProxy) GetAllItems(ctx context.Context, req *peering.GetAllItemsRequest) (*peering.GetAllItemsResponse, error)
- func (p *PeeringProxy) GetItem(ctx context.Context, req *peering.GetItemRequest) (*peering.GetItemResponse, error)
- func (p *PeeringProxy) PutItem(ctx context.Context, req *peering.PutItemRequest) (*peering.Empty, error)
- type Proxy
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func StartAPIProxy ¶
Types ¶
type APIProxy ¶
type APIProxy struct {
// contains filtered or unexported fields
}
func (*APIProxy) AddReplica ¶
func (a *APIProxy) AddReplica(ctx context.Context, req *client.AddReplicaRequest) (*client.Empty, error)
AddReplica calls this method on the exthandler
func (*APIProxy) AddTrigger ¶
func (a *APIProxy) AddTrigger(ctx context.Context, req *client.AddTriggerRequest) (*client.Empty, error)
AddTrigger calls this method on the exthandler
func (*APIProxy) Append ¶
func (a *APIProxy) Append(ctx context.Context, req *client.AppendRequest) (*client.AppendResponse, error)
Append calls this method on the exthandler
func (*APIProxy) CreateKeygroup ¶
func (a *APIProxy) CreateKeygroup(ctx context.Context, req *client.CreateKeygroupRequest) (*client.Empty, error)
CreateKeygroup calls this method on the exthandler
func (*APIProxy) Delete ¶
func (a *APIProxy) Delete(ctx context.Context, req *client.DeleteRequest) (*client.DeleteResponse, error)
Delete calls this method on the exthandler
func (*APIProxy) DeleteKeygroup ¶
func (a *APIProxy) DeleteKeygroup(ctx context.Context, req *client.DeleteKeygroupRequest) (*client.Empty, error)
DeleteKeygroup calls this method on the exthandler
func (*APIProxy) GetAllReplica ¶
func (a *APIProxy) GetAllReplica(ctx context.Context, req *client.Empty) (*client.GetAllReplicaResponse, error)
GetAllReplica calls this method on the exthandler
func (*APIProxy) GetKeygroupInfo ¶ added in v0.2.2
func (a *APIProxy) GetKeygroupInfo(ctx context.Context, req *client.GetKeygroupInfoRequest) (*client.GetKeygroupInfoResponse, error)
GetKeygroupInfo calls this method on the exthandler
func (*APIProxy) GetKeygroupTriggers ¶
func (a *APIProxy) GetKeygroupTriggers(ctx context.Context, req *client.GetKeygroupTriggerRequest) (*client.GetKeygroupTriggerResponse, error)
GetKeygroupTriggers calls this method on the exthandler
func (*APIProxy) GetReplica ¶
func (a *APIProxy) GetReplica(ctx context.Context, req *client.GetReplicaRequest) (*client.GetReplicaResponse, error)
GetReplica calls this method on the exthandler
func (*APIProxy) Read ¶
func (a *APIProxy) Read(ctx context.Context, req *client.ReadRequest) (*client.ReadResponse, error)
Read calls this method on the exthandler
func (*APIProxy) RemoveReplica ¶
func (a *APIProxy) RemoveReplica(ctx context.Context, req *client.RemoveReplicaRequest) (*client.Empty, error)
RemoveReplica calls this method on the exthandler
func (*APIProxy) RemoveTrigger ¶
func (a *APIProxy) RemoveTrigger(ctx context.Context, req *client.RemoveTriggerRequest) (*client.Empty, error)
RemoveTrigger calls this method on the exthandler
func (*APIProxy) RemoveUser ¶
func (a *APIProxy) RemoveUser(ctx context.Context, req *client.RemoveUserRequest) (*client.Empty, error)
RemoveUser calls this method on the exthandler
func (*APIProxy) Scan ¶
func (a *APIProxy) Scan(ctx context.Context, req *client.ScanRequest) (*client.ScanResponse, error)
Scan calls this method on the exthandler
func (*APIProxy) Update ¶
func (a *APIProxy) Update(ctx context.Context, req *client.UpdateRequest) (*client.UpdateResponse, error)
Update calls this method on the exthandler
type PeeringProxy ¶
type PeeringProxy struct {
// contains filtered or unexported fields
}
func (*PeeringProxy) AppendItem ¶
func (p *PeeringProxy) AppendItem(ctx context.Context, req *peering.AppendItemRequest) (*peering.Empty, error)
AppendItem calls HandleAppend on the Inthandler
func (*PeeringProxy) CreateKeygroup ¶
func (p *PeeringProxy) CreateKeygroup(ctx context.Context, req *peering.CreateKeygroupRequest) (*peering.Empty, error)
CreateKeygroup calls this Method on the Inthandler
func (*PeeringProxy) DeleteKeygroup ¶
func (p *PeeringProxy) DeleteKeygroup(ctx context.Context, req *peering.DeleteKeygroupRequest) (*peering.Empty, error)
DeleteKeygroup calls this Method on the Inthandler
func (*PeeringProxy) GetAllItems ¶
func (p *PeeringProxy) GetAllItems(ctx context.Context, req *peering.GetAllItemsRequest) (*peering.GetAllItemsResponse, error)
GetAllItems has no implementation
func (*PeeringProxy) GetItem ¶
func (p *PeeringProxy) GetItem(ctx context.Context, req *peering.GetItemRequest) (*peering.GetItemResponse, error)
GetItem has no implementation
func (*PeeringProxy) PutItem ¶
func (p *PeeringProxy) PutItem(ctx context.Context, req *peering.PutItemRequest) (*peering.Empty, error)
PutItem calls HandleUpdate on the Inthandler