proxy

package
v0.2.8 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 7, 2023 License: MIT Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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.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 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

type Proxy 

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

func NewProxy 

func NewProxy(hosts []string) *Proxy

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.