synclet

Documentation

Index

• Constants
• type GRPCServer
  • func NewGRPCServer(del syncletDelegate) *GRPCServer
  • func (s *GRPCServer) UpdateContainer(req *proto.UpdateContainerRequest, server proto.Synclet_UpdateContainerServer) error
• type Synclet
  • func NewSynclet(dCli docker.Client) *Synclet
  • func WireSynclet(ctx context.Context, runtime container.Runtime) (*Synclet, error)
  • func (s Synclet) UpdateContainer(ctx context.Context, containerId container.ID, tarArchive []byte, ...) error
• type SyncletCli
  • func NewGRPCClient(conn *grpc.ClientConn) *SyncletCli
  • func (s *SyncletCli) Close() error
  • func (s *SyncletCli) UpdateContainer(ctx context.Context, containerId container.ID, tarArchive []byte, ...) error
• type SyncletClient
  • func FakeGRPCWrapper(ctx context.Context, c *TestSyncletClient) (SyncletClient, error)
• type TestSyncletClient
  • func NewTestSyncletClient(dCli docker.Client) *TestSyncletClient
  • func (c *TestSyncletClient) Close() error
  • func (c *TestSyncletClient) UpdateContainer(ctx context.Context, containerID container.ID, tarArchive []byte, ...) error

Constants

const Port = 23551

Types

type GRPCServer

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

func NewGRPCServer

func NewGRPCServer(del syncletDelegate) *GRPCServer

func (*GRPCServer) UpdateContainer

func (s *GRPCServer) UpdateContainer(req *proto.UpdateContainerRequest, server proto.Synclet_UpdateContainerServer) error

type Synclet

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

func NewSynclet

func NewSynclet(dCli docker.Client) *Synclet

func WireSynclet

func WireSynclet(ctx context.Context, runtime container.Runtime) (*Synclet, error)

func (Synclet) UpdateContainer

func (s Synclet) UpdateContainer(
	ctx context.Context,
	containerId container.ID,
	tarArchive []byte,
	filesToDelete []string,
	commands []model.Cmd,
	hotReload bool) error

type SyncletCli

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

func NewGRPCClient

func NewGRPCClient(conn *grpc.ClientConn) *SyncletCli

func (*SyncletCli) Close

func (s *SyncletCli) Close() error

func (*SyncletCli) UpdateContainer

func (s *SyncletCli) UpdateContainer(
	ctx context.Context,
	containerId container.ID,
	tarArchive []byte,
	filesToDelete []string,
	commands []model.Cmd,
	hotReload bool) error

type SyncletClient

type SyncletClient interface {
	UpdateContainer(ctx context.Context, containerID container.ID, tarArchive []byte,
		filesToDelete []string, commands []model.Cmd, hotReload bool) error

	Close() error
}

func FakeGRPCWrapper

func FakeGRPCWrapper(ctx context.Context, c *TestSyncletClient) (SyncletClient, error)

type TestSyncletClient

type TestSyncletClient struct {

	// To make sure that any Docker calls we're asserting on
	// came via the synclet (and not through some other path
	// to the same Docker client)
	UpdateContainerCount int

	// To make sure client was configured correctly by SyncletClientManager
	PodID     k8s.PodID
	Namespace k8s.Namespace
	// contains filtered or unexported fields
}

func NewTestSyncletClient

func NewTestSyncletClient(dCli docker.Client) *TestSyncletClient

func (*TestSyncletClient) Close

func (c *TestSyncletClient) Close() error

func (*TestSyncletClient) UpdateContainer

func (c *TestSyncletClient) UpdateContainer(ctx context.Context, containerID container.ID,
	tarArchive []byte, filesToDelete []string, commands []model.Cmd, hotReload bool) error