proxy

Documentation

Index

• func StartAPIProxy(p *Proxy, port int, cert string, key string, caCert string, skipVerify bool) (*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
  • func NewProxy(hosts []string) *Proxy

Functions

func StartAPIProxy

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

func StartPeeringProxy

func StartPeeringProxy(p *Proxy, port int, certFile string, keyFile string, caFile string, skipVerify bool) (*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.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) AddUser

func (a *APIProxy) AddUser(ctx context.Context, req *client.AddUserRequest) (*client.Empty, 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.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

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

type Proxy

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

func NewProxy

func NewProxy(hosts []string) *Proxy