rpc

Documentation

Index

• func AgentServe(ctx context.Context, client redis.UniversalClient, url, fromStorage string) error
• func ProxyServe(ctx context.Context, client redis.UniversalClient, proxy Proxy) error
• type AgentClient
  • func NewAgentClient(client redis.UniversalClient) *AgentClient
  • func (a *AgentClient) Ping(ctx context.Context) ([]AgentInfo, error)
• type AgentInfo
• type GetCredentialsResp
• type Proxy
  • func NewProxyClient(client redis.UniversalClient) Proxy
• type ProxyClient
  • func (c *ProxyClient) GetCredentials(ctx context.Context) (*pb.GetProxyCredentialsResponse, error)
• type ProxyGetCredentials
  • func (f ProxyGetCredentials) GetCredentials(ctx context.Context) (*pb.GetProxyCredentialsResponse, error)

Functions

func AgentServe

func AgentServe(ctx context.Context, client redis.UniversalClient, url, fromStorage string) error

func ProxyServe

func ProxyServe(ctx context.Context, client redis.UniversalClient, proxy Proxy) error

Types

type AgentClient

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

func NewAgentClient

func NewAgentClient(client redis.UniversalClient) *AgentClient

func (*AgentClient) Ping

func (a *AgentClient) Ping(ctx context.Context) ([]AgentInfo, error)

type AgentInfo

type AgentInfo struct {
	URL         string
	FromStorage string
}

type GetCredentialsResp

type GetCredentialsResp struct {
	Address string
	Creds   map[string]s3.CredentialsV4
}

type Proxy

type Proxy interface {
	GetCredentials(ctx context.Context) (*pb.GetProxyCredentialsResponse, error)
}

func NewProxyClient

func NewProxyClient(client redis.UniversalClient) Proxy

type ProxyClient

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

func (*ProxyClient) GetCredentials

func (c *ProxyClient) GetCredentials(ctx context.Context) (*pb.GetProxyCredentialsResponse, error)

type ProxyGetCredentials

type ProxyGetCredentials func(ctx context.Context) (*pb.GetProxyCredentialsResponse, error)

func (ProxyGetCredentials) GetCredentials

func (f ProxyGetCredentials) GetCredentials(ctx context.Context) (*pb.GetProxyCredentialsResponse, error)