 Documentation
      ¶
      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)
 
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
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 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 (*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 ¶
 Click to show internal directories. 
   Click to hide internal directories.