proxy

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.StatusResponse, error)
  • func (a *APIProxy) AddTrigger(ctx context.Context, req *client.AddTriggerRequest) (*client.StatusResponse, error)
  • func (a *APIProxy) AddUser(ctx context.Context, req *client.UserRequest) (*client.StatusResponse, 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.StatusResponse, error)
  • func (a *APIProxy) Delete(ctx context.Context, req *client.DeleteRequest) (*client.StatusResponse, error)
  • func (a *APIProxy) DeleteKeygroup(ctx context.Context, req *client.DeleteKeygroupRequest) (*client.StatusResponse, error)
  • func (a *APIProxy) GetAllReplica(ctx context.Context, req *client.GetAllReplicaRequest) (*client.GetAllReplicaResponse, error)
  • func (a *APIProxy) GetKeygroupReplica(ctx context.Context, req *client.GetKeygroupReplicaRequest) (*client.GetKeygroupReplicaResponse, 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.StatusResponse, error)
  • func (a *APIProxy) RemoveTrigger(ctx context.Context, req *client.RemoveTriggerRequest) (*client.StatusResponse, error)
  • func (a *APIProxy) RemoveUser(ctx context.Context, req *client.UserRequest) (*client.StatusResponse, 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.StatusResponse, error)
• type PeeringProxy
  • func (p *PeeringProxy) AddReplica(ctx context.Context, req *peering.AddReplicaRequest) (*peering.Empty, error)
  • 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) DeleteItem(ctx context.Context, req *peering.DeleteItemRequest) (*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)
  • func (p *PeeringProxy) RemoveReplica(ctx context.Context, req *peering.RemoveReplicaRequest) (*peering.Empty, error)
• type Proxy
  • func NewProxy(hosts []string) *Proxy

Functions

func StartAPIProxy

func StartAPIProxy(p *Proxy, port int, cert string, key string, caCert string) (*grpc.Server, error)

func StartPeeringProxy

func StartPeeringProxy(p *Proxy, port int, certFile string, keyFile string, caFile string) (*grpc.Server, error)

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.StatusResponse, error)

AddReplica calls this method on the exthandler

func (*APIProxy) AddTrigger

func (a *APIProxy) AddTrigger(ctx context.Context, req *client.AddTriggerRequest) (*client.StatusResponse, error)

AddTrigger calls this method on the exthandler

func (*APIProxy) AddUser

func (a *APIProxy) AddUser(ctx context.Context, req *client.UserRequest) (*client.StatusResponse, error)

AddUser 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.StatusResponse, error)

CreateKeygroup calls this method on the exthandler

func (*APIProxy) Delete

func (a *APIProxy) Delete(ctx context.Context, req *client.DeleteRequest) (*client.StatusResponse, error)

Delete calls this method on the exthandler

func (*APIProxy) DeleteKeygroup

func (a *APIProxy) DeleteKeygroup(ctx context.Context, req *client.DeleteKeygroupRequest) (*client.StatusResponse, error)

DeleteKeygroup calls this method on the exthandler

func (*APIProxy) GetAllReplica

func (a *APIProxy) GetAllReplica(ctx context.Context, req *client.GetAllReplicaRequest) (*client.GetAllReplicaResponse, error)

GetAllReplica calls this method on the exthandler

func (*APIProxy) GetKeygroupReplica

func (a *APIProxy) GetKeygroupReplica(ctx context.Context, req *client.GetKeygroupReplicaRequest) (*client.GetKeygroupReplicaResponse, error)

GetKeygroupReplica 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.StatusResponse, error)

RemoveReplica calls this method on the exthandler

func (*APIProxy) RemoveTrigger

func (a *APIProxy) RemoveTrigger(ctx context.Context, req *client.RemoveTriggerRequest) (*client.StatusResponse, error)

RemoveTrigger calls this method on the exthandler

func (*APIProxy) RemoveUser

func (a *APIProxy) RemoveUser(ctx context.Context, req *client.UserRequest) (*client.StatusResponse, 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.StatusResponse, error)

Update calls this method on the exthandler

type PeeringProxy

type PeeringProxy struct {
	// contains filtered or unexported fields
}

func (*PeeringProxy) AddReplica

func (p *PeeringProxy) AddReplica(ctx context.Context, req *peering.AddReplicaRequest) (*peering.Empty, error)

AddReplica calls this Method on the Inthandler

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) DeleteItem

func (p *PeeringProxy) DeleteItem(ctx context.Context, req *peering.DeleteItemRequest) (*peering.Empty, error)

DeleteItem has no implementation

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

func (*PeeringProxy) RemoveReplica

func (p *PeeringProxy) RemoveReplica(ctx context.Context, req *peering.RemoveReplicaRequest) (*peering.Empty, error)

RemoveReplica calls this Method on the Inthandler

type Proxy

type Proxy struct {
	// contains filtered or unexported fields
}

func NewProxy

func NewProxy(hosts []string) *Proxy