entrypoint

Documentation

Index

• Variables
• func CaptureAllProcessLogs(readyChannel chan string, loggingClient log_sink_server.LogSink_RecordClient) error
• func New(args []string, ctx context.Context) *entrypoint
• func RegisterSyncServer(s *grpc.Server, srv SyncServer)
• type Action
  • func (*Action) Descriptor() ([]byte, []int)
  • func (x *Action) GetCommand() []string
  • func (x *Action) GetPatterns() []string
  • func (x *Action) GetWorkdir() string
  • func (*Action) ProtoMessage()
  • func (x *Action) ProtoReflect() protoreflect.Message
  • func (x *Action) Reset()
  • func (x *Action) String() string
• type File
  • func (*File) Descriptor() ([]byte, []int)
  • func (x *File) GetExists() bool
  • func (x *File) GetHash() string
  • func (x *File) GetName() string
  • func (x *File) GetNew() bool
  • func (x *File) GetRelName() string
  • func (x *File) GetSymlinkTarget() string
  • func (x *File) GetType() string
  • func (*File) ProtoMessage()
  • func (x *File) ProtoReflect() protoreflect.Message
  • func (x *File) Reset()
  • func (x *File) String() string
• type FileChangeAck
  • func (*FileChangeAck) Descriptor() ([]byte, []int)
  • func (*FileChangeAck) ProtoMessage()
  • func (x *FileChangeAck) ProtoReflect() protoreflect.Message
  • func (x *FileChangeAck) Reset()
  • func (x *FileChangeAck) String() string
• type FileChangeNotification
  • func (*FileChangeNotification) Descriptor() ([]byte, []int)
  • func (x *FileChangeNotification) GetActions() []*Action
  • func (x *FileChangeNotification) GetArchive() []byte
  • func (x *FileChangeNotification) GetFiles() []*File
  • func (x *FileChangeNotification) GetRoot() string
  • func (*FileChangeNotification) ProtoMessage()
  • func (x *FileChangeNotification) ProtoReflect() protoreflect.Message
  • func (x *FileChangeNotification) Reset()
  • func (x *FileChangeNotification) String() string
• type SyncClient
  • func NewSyncClient(cc grpc.ClientConnInterface) SyncClient
• type SyncServer
• type Sync_StreamFileChangeClient
• type Sync_StreamFileChangeServer
• type UnimplementedSyncServer
  • func (*UnimplementedSyncServer) StreamFileChange(Sync_StreamFileChangeServer) error

Variables

var File_entrypoint_proto protoreflect.FileDescriptor

Functions

func CaptureAllProcessLogs

func CaptureAllProcessLogs(readyChannel chan string, loggingClient log_sink_server.LogSink_RecordClient) error

CaptureAllProcessLogs intercepts StdIO so it can be multiplexed to multiple writers one of which is sending log lines to the log sink server via the log sink client

func New

func New(args []string, ctx context.Context) *entrypoint

New instantiates a new ark entrypoint server

func RegisterSyncServer

func RegisterSyncServer(s *grpc.Server, srv SyncServer)

Types

type Action

type Action struct {
	Command  []string `protobuf:"bytes,1,rep,name=command,proto3" json:"command,omitempty"`
	Workdir  string   `protobuf:"bytes,2,opt,name=workdir,proto3" json:"workdir,omitempty"`
	Patterns []string `protobuf:"bytes,3,rep,name=patterns,proto3" json:"patterns,omitempty"`
	// contains filtered or unexported fields
}

func (*Action) Descriptor

func (*Action) Descriptor() ([]byte, []int)

Deprecated: Use Action.ProtoReflect.Descriptor instead.

func (*Action) GetCommand

func (x *Action) GetCommand() []string

func (*Action) GetPatterns

func (x *Action) GetPatterns() []string

func (*Action) GetWorkdir

func (x *Action) GetWorkdir() string

func (*Action) ProtoMessage

func (*Action) ProtoMessage()

func (*Action) ProtoReflect

func (x *Action) ProtoReflect() protoreflect.Message

func (*Action) Reset

func (x *Action) Reset()

func (*Action) String

func (x *Action) String() string

type File

type File struct {
	Name          string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Exists        bool   `protobuf:"varint,2,opt,name=exists,proto3" json:"exists,omitempty"`
	New           bool   `protobuf:"varint,3,opt,name=new,proto3" json:"new,omitempty"`
	Type          string `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"`
	Hash          string `protobuf:"bytes,5,opt,name=hash,proto3" json:"hash,omitempty"`
	SymlinkTarget string `protobuf:"bytes,6,opt,name=symlink_target,json=symlinkTarget,proto3" json:"symlink_target,omitempty"`
	RelName       string `protobuf:"bytes,7,opt,name=rel_name,json=relName,proto3" json:"rel_name,omitempty"`
	// contains filtered or unexported fields
}

func (*File) Descriptor

func (*File) Descriptor() ([]byte, []int)

Deprecated: Use File.ProtoReflect.Descriptor instead.

func (*File) GetExists

func (x *File) GetExists() bool

func (*File) GetHash

func (x *File) GetHash() string

func (*File) GetName

func (x *File) GetName() string

func (*File) GetNew

func (x *File) GetNew() bool

func (*File) GetRelName

func (x *File) GetRelName() string

func (*File) GetSymlinkTarget

func (x *File) GetSymlinkTarget() string

func (*File) GetType

func (x *File) GetType() string

func (*File) ProtoMessage

func (*File) ProtoMessage()

func (*File) ProtoReflect

func (x *File) ProtoReflect() protoreflect.Message

func (*File) Reset

func (x *File) Reset()

func (*File) String

func (x *File) String() string

type FileChangeAck

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

func (*FileChangeAck) Descriptor

func (*FileChangeAck) Descriptor() ([]byte, []int)

Deprecated: Use FileChangeAck.ProtoReflect.Descriptor instead.

func (*FileChangeAck) ProtoMessage

func (*FileChangeAck) ProtoMessage()

func (*FileChangeAck) ProtoReflect

func (x *FileChangeAck) ProtoReflect() protoreflect.Message

func (*FileChangeAck) Reset

func (x *FileChangeAck) Reset()

func (*FileChangeAck) String

func (x *FileChangeAck) String() string

type FileChangeNotification

type FileChangeNotification struct {
	Files   []*File   `protobuf:"bytes,1,rep,name=files,proto3" json:"files,omitempty"`
	Archive []byte    `protobuf:"bytes,2,opt,name=archive,proto3" json:"archive,omitempty"`
	Root    string    `protobuf:"bytes,3,opt,name=root,proto3" json:"root,omitempty"`
	Actions []*Action `protobuf:"bytes,4,rep,name=actions,proto3" json:"actions,omitempty"`
	// contains filtered or unexported fields
}

func (*FileChangeNotification) Descriptor

func (*FileChangeNotification) Descriptor() ([]byte, []int)

Deprecated: Use FileChangeNotification.ProtoReflect.Descriptor instead.

func (*FileChangeNotification) GetActions

func (x *FileChangeNotification) GetActions() []*Action

func (*FileChangeNotification) GetArchive

func (x *FileChangeNotification) GetArchive() []byte

func (*FileChangeNotification) GetFiles

func (x *FileChangeNotification) GetFiles() []*File

func (*FileChangeNotification) GetRoot

func (x *FileChangeNotification) GetRoot() string

func (*FileChangeNotification) ProtoMessage

func (*FileChangeNotification) ProtoMessage()

func (*FileChangeNotification) ProtoReflect

func (x *FileChangeNotification) ProtoReflect() protoreflect.Message

func (*FileChangeNotification) Reset

func (x *FileChangeNotification) Reset()

func (*FileChangeNotification) String

func (x *FileChangeNotification) String() string

type SyncClient

type SyncClient interface {
	StreamFileChange(ctx context.Context, opts ...grpc.CallOption) (Sync_StreamFileChangeClient, error)
}

SyncClient is the client API for Sync service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewSyncClient

func NewSyncClient(cc grpc.ClientConnInterface) SyncClient

type SyncServer

type SyncServer interface {
	StreamFileChange(Sync_StreamFileChangeServer) error
}

SyncServer is the server API for Sync service.

type Sync_StreamFileChangeClient

type Sync_StreamFileChangeClient interface {
	Send(*FileChangeNotification) error
	Recv() (*FileChangeAck, error)
	grpc.ClientStream
}

type Sync_StreamFileChangeServer

type Sync_StreamFileChangeServer interface {
	Send(*FileChangeAck) error
	Recv() (*FileChangeNotification, error)
	grpc.ServerStream
}

type UnimplementedSyncServer

type UnimplementedSyncServer struct {
}

UnimplementedSyncServer can be embedded to have forward compatible implementations.

func (*UnimplementedSyncServer) StreamFileChange

func (*UnimplementedSyncServer) StreamFileChange(Sync_StreamFileChangeServer) error