proxy

Documentation

Index

• func NewProxy(kvClient Client, pushEnabled bool, logger log.Logger, ...) *grpc.Server
• type Client
• type LoggerFactory
• type Proxy
  • func (p *Proxy) Get(ctx context.Context, request *llvmcas.CASGetRequest) (*llvmcas.CASGetResponse, error)
  • func (p *Proxy) GetSessionStats(_ context.Context, _ *emptypb.Empty) (*session.GetSessionStatsResponse, error)
  • func (p *Proxy) GetValue(ctx context.Context, request *llvmkv.GetValueRequest) (*llvmkv.GetValueResponse, error)
  • func (p *Proxy) Load(ctx context.Context, request *llvmcas.CASLoadRequest) (*llvmcas.CASLoadResponse, error)
  • func (p *Proxy) Put(ctx context.Context, request *llvmcas.CASPutRequest) (*llvmcas.CASPutResponse, error)
  • func (p *Proxy) PutValue(ctx context.Context, request *llvmkv.PutValueRequest) (*llvmkv.PutValueResponse, error)
  • func (p *Proxy) Save(ctx context.Context, request *llvmcas.CASSaveRequest) (*llvmcas.CASSaveResponse, error)
  • func (p *Proxy) SetSession(_ context.Context, request *session.SetSessionRequest) (*emptypb.Empty, error)

Functions

func NewProxy

func NewProxy(kvClient Client, pushEnabled bool, logger log.Logger, loggerFactory LoggerFactory) *grpc.Server

Types

type Client

type Client interface {
	ChangeSession(invocationID string, appSlug string, buildSlug string, stepSlug string)
	SetLogger(logger log.Logger)
	DownloadStream(ctx context.Context, writer io.Writer, key string) error
	UploadStreamToBuildCache(ctx context.Context, reader io.Reader, key string, size int64) error
	GetCapabilitiesWithRetry(ctx context.Context) error
}

type LoggerFactory

type LoggerFactory func(invocationID string) (log.Logger, error)

type Proxy

type Proxy struct {
	llvmcas.UnimplementedCASDBServiceServer
	llvmkv.UnimplementedKeyValueDBServer
	session.UnimplementedSessionServer
	// contains filtered or unexported fields
}

func (*Proxy) Get

func (p *Proxy) Get(ctx context.Context, request *llvmcas.CASGetRequest) (*llvmcas.CASGetResponse, error)

func (*Proxy) GetSessionStats

func (p *Proxy) GetSessionStats(_ context.Context, _ *emptypb.Empty) (*session.GetSessionStatsResponse, error)

func (*Proxy) GetValue

func (p *Proxy) GetValue(ctx context.Context, request *llvmkv.GetValueRequest) (*llvmkv.GetValueResponse, error)

func (*Proxy) Load

func (p *Proxy) Load(ctx context.Context, request *llvmcas.CASLoadRequest) (*llvmcas.CASLoadResponse, error)

func (*Proxy) Put

func (p *Proxy) Put(ctx context.Context, request *llvmcas.CASPutRequest) (*llvmcas.CASPutResponse, error)

func (*Proxy) PutValue

func (p *Proxy) PutValue(ctx context.Context, request *llvmkv.PutValueRequest) (*llvmkv.PutValueResponse, error)

func (*Proxy) Save

func (p *Proxy) Save(ctx context.Context, request *llvmcas.CASSaveRequest) (*llvmcas.CASSaveResponse, error)

func (*Proxy) SetSession

func (p *Proxy) SetSession(_ context.Context, request *session.SetSessionRequest) (*emptypb.Empty, error)