filesystem

Documentation

Index

• func Handle(server *chi.Mux, l *zerolog.Logger)
• type FileWatcher
  • func CreateFileWatcher(watchPath, operationID string, logger *zerolog.Logger) (*FileWatcher, error)
  • func (fw *FileWatcher) Close()
• type Service
  • func (s Service) CreateWatcher(ctx context.Context, req *connect.Request[rpc.CreateWatcherRequest]) (*connect.Response[rpc.CreateWatcherResponse], error)
  • func (s Service) GetWatcherEvents(_ context.Context, req *connect.Request[rpc.GetWatcherEventsRequest]) (*connect.Response[rpc.GetWatcherEventsResponse], error)
  • func (Service) ListDir(ctx context.Context, req *connect.Request[rpc.ListDirRequest]) (*connect.Response[rpc.ListDirResponse], error)
  • func (Service) MakeDir(ctx context.Context, req *connect.Request[rpc.MakeDirRequest]) (*connect.Response[rpc.MakeDirResponse], error)
  • func (Service) Move(ctx context.Context, req *connect.Request[rpc.MoveRequest]) (*connect.Response[rpc.MoveResponse], error)
  • func (Service) Remove(ctx context.Context, req *connect.Request[rpc.RemoveRequest]) (*connect.Response[rpc.RemoveResponse], error)
  • func (s Service) RemoveWatcher(_ context.Context, req *connect.Request[rpc.RemoveWatcherRequest]) (*connect.Response[rpc.RemoveWatcherResponse], error)
  • func (Service) Stat(ctx context.Context, req *connect.Request[rpc.StatRequest]) (*connect.Response[rpc.StatResponse], error)
  • func (s Service) WatchDir(ctx context.Context, req *connect.Request[rpc.WatchDirRequest], ...) error

Functions

func Handle

func Handle(server *chi.Mux, l *zerolog.Logger)

Types

type FileWatcher

type FileWatcher struct {
	Events []*rpc.FilesystemEvent

	Error error

	Lock sync.Mutex
	// contains filtered or unexported fields
}

func CreateFileWatcher

func CreateFileWatcher(watchPath, operationID string, logger *zerolog.Logger) (*FileWatcher, error)

func (*FileWatcher) Close

func (fw *FileWatcher) Close()

type Service

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

func (Service) CreateWatcher

func (s Service) CreateWatcher(ctx context.Context, req *connect.Request[rpc.CreateWatcherRequest]) (*connect.Response[rpc.CreateWatcherResponse], error)

func (Service) GetWatcherEvents

func (s Service) GetWatcherEvents(_ context.Context, req *connect.Request[rpc.GetWatcherEventsRequest]) (*connect.Response[rpc.GetWatcherEventsResponse], error)

func (Service) ListDir

func (Service) ListDir(ctx context.Context, req *connect.Request[rpc.ListDirRequest]) (*connect.Response[rpc.ListDirResponse], error)

func (Service) MakeDir

func (Service) MakeDir(ctx context.Context, req *connect.Request[rpc.MakeDirRequest]) (*connect.Response[rpc.MakeDirResponse], error)

func (Service) Move

func (Service) Move(ctx context.Context, req *connect.Request[rpc.MoveRequest]) (*connect.Response[rpc.MoveResponse], error)

func (Service) Remove

func (Service) Remove(ctx context.Context, req *connect.Request[rpc.RemoveRequest]) (*connect.Response[rpc.RemoveResponse], error)

func (Service) RemoveWatcher

func (s Service) RemoveWatcher(_ context.Context, req *connect.Request[rpc.RemoveWatcherRequest]) (*connect.Response[rpc.RemoveWatcherResponse], error)

func (Service) Stat

func (Service) Stat(ctx context.Context, req *connect.Request[rpc.StatRequest]) (*connect.Response[rpc.StatResponse], error)

func (Service) WatchDir

func (s Service) WatchDir(ctx context.Context, req *connect.Request[rpc.WatchDirRequest], stream *connect.ServerStream[rpc.WatchDirResponse]) error