synclet

Documentation

Index

• Constants
• type FakeSyncletClient
  • func NewFakeSyncletClient() *FakeSyncletClient
  • func (c *FakeSyncletClient) Close() error
  • func (c *FakeSyncletClient) ContainerIDForPod(ctx context.Context, podID k8s.PodID, imageID reference.NamedTagged) (k8s.ContainerID, error)
  • func (c *FakeSyncletClient) UpdateContainer(ctx context.Context, containerID k8s.ContainerID, tarArchive []byte, ...) error
• type GRPCServer
  • func NewGRPCServer(del *Synclet) *GRPCServer
  • func (s *GRPCServer) GetContainerIdForPod(req *proto.GetContainerIdForPodRequest, ...) error
  • func (s *GRPCServer) UpdateContainer(req *proto.UpdateContainerRequest, server proto.Synclet_UpdateContainerServer) error
• type Synclet
  • func NewSynclet(dcli docker.DockerClient, cr *build.ContainerResolver) *Synclet
  • func WireSynclet(ctx context.Context, env k8s.Env) (*Synclet, error)
  • func (s Synclet) ContainerIDForPod(ctx context.Context, podID k8s.PodID, imageID reference.NamedTagged) (k8s.ContainerID, error)
  • func (s Synclet) UpdateContainer(ctx context.Context, containerId k8s.ContainerID, tarArchive []byte, ...) error
• type SyncletCli
  • func NewGRPCClient(conn *grpc.ClientConn) *SyncletCli
  • func (s *SyncletCli) Close() error
  • func (s *SyncletCli) ContainerIDForPod(ctx context.Context, podID k8s.PodID, imageID reference.NamedTagged) (cID k8s.ContainerID, err error)
  • func (s *SyncletCli) UpdateContainer(ctx context.Context, containerId k8s.ContainerID, tarArchive []byte, ...) error
• type SyncletClient

Constants

const Port = 23551

Types

type FakeSyncletClient

type FakeSyncletClient struct {
	UpdateContainerCount         int
	ClosedCount                  int
	UpdateContainerErrorToReturn error
	PodID                        k8s.PodID
	Namespace                    k8s.Namespace
}

NOTE(maia): idk if we even need this -- maybe what we want is a real synclet client with a fake docker client inside it. But ¯\_(ツ)_/¯

func NewFakeSyncletClient

func NewFakeSyncletClient() *FakeSyncletClient

func (*FakeSyncletClient) Close

func (c *FakeSyncletClient) Close() error

func (*FakeSyncletClient) ContainerIDForPod

func (c *FakeSyncletClient) ContainerIDForPod(ctx context.Context, podID k8s.PodID, imageID reference.NamedTagged) (k8s.ContainerID, error)

func (*FakeSyncletClient) UpdateContainer

func (c *FakeSyncletClient) UpdateContainer(ctx context.Context, containerID k8s.ContainerID,
	tarArchive []byte, filesToDelete []string, commands []model.Cmd) error

type GRPCServer

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

func NewGRPCServer

func NewGRPCServer(del *Synclet) *GRPCServer

func (*GRPCServer) GetContainerIdForPod

func (s *GRPCServer) GetContainerIdForPod(req *proto.GetContainerIdForPodRequest, server proto.Synclet_GetContainerIdForPodServer) error

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.DockerClient, cr *build.ContainerResolver) *Synclet

func WireSynclet

func WireSynclet(ctx context.Context, env k8s.Env) (*Synclet, error)

func (Synclet) ContainerIDForPod

func (s Synclet) ContainerIDForPod(ctx context.Context, podID k8s.PodID, imageID reference.NamedTagged) (k8s.ContainerID, error)

func (Synclet) UpdateContainer

func (s Synclet) UpdateContainer(
	ctx context.Context,
	containerId k8s.ContainerID,
	tarArchive []byte,
	filesToDelete []string,
	commands []model.Cmd) 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) ContainerIDForPod

func (s *SyncletCli) ContainerIDForPod(ctx context.Context, podID k8s.PodID, imageID reference.NamedTagged) (cID k8s.ContainerID, err error)

func (*SyncletCli) UpdateContainer

func (s *SyncletCli) UpdateContainer(
	ctx context.Context,
	containerId k8s.ContainerID,
	tarArchive []byte,
	filesToDelete []string,
	commands []model.Cmd) error

type SyncletClient

type SyncletClient interface {
	UpdateContainer(ctx context.Context, containerID k8s.ContainerID, tarArchive []byte,
		filesToDelete []string, commands []model.Cmd) error
	ContainerIDForPod(ctx context.Context, podID k8s.PodID, imageID reference.NamedTagged) (k8s.ContainerID, error)

	Close() error
}