Diffstat (limited to 'internal/client/input')
| -rw-r--r-- | internal/client/input/b2.go | 7 | ||||
| -rw-r--r-- | internal/client/input/input_client_interface.go | 1 | ||||
| -rw-r--r-- | internal/client/input/local_unix.go | 4 |
3 files changed, 1 insertions, 11 deletions
diff --git a/internal/client/input/b2.go b/internal/client/input/b2.go index fe94333..db68268 100644 --- a/internal/client/input/b2.go +++ b/internal/client/input/b2.go @@ -16,7 +16,6 @@ var _ InputClient = (*B2InputClient)(nil) type B2InputClient struct { prefix string bucket *b2.Bucket - bucketName string b2cl *b2.Client knownExtensions []string } @@ -37,7 +36,7 @@ func NewB2InputClient(cfg *config.InputConfig) (InputClient, error) { return nil, err } - return &B2InputClient{b2cl: b2cl, bucket: bucket, bucketName: b2cfg.BucketName, prefix: b2cfg.Prefix, knownExtensions: cfg.KnownExtensions}, nil + return &B2InputClient{b2cl: b2cl, bucket: bucket, prefix: b2cfg.Prefix, knownExtensions: cfg.KnownExtensions}, nil } func (c *B2InputClient) Scan() ([]string, error) { @@ -121,10 +120,6 @@ func (c *B2InputClient) ReadMetadata(path string) (*MetadataStruct, error) { return &metadata, nil } -func (c *B2InputClient) ID(path string) string { - return fmt.Sprintf("b2://%s/%s%s", c.bucketName, c.prefix, path) -} - func (c *B2InputClient) GetReader(path string) (io.ReadCloser, error) { obj := c.bucket.Object(c.prefix + path) if obj == nil { diff --git a/internal/client/input/input_client_interface.go b/internal/client/input/input_client_interface.go index a2cf84b..4930aa0 100644 --- a/internal/client/input/input_client_interface.go +++ b/internal/client/input/input_client_interface.go @@ -11,7 +11,6 @@ type InputClient interface { Scan() ([]string, error) ReadMetadata(string) (*MetadataStruct, error) GetReader(string) (io.ReadCloser, error) - ID(path string) string } type MetadataStruct struct { diff --git a/internal/client/input/local_unix.go b/internal/client/input/local_unix.go index 21b08a9..e509c8b 100644 --- a/internal/client/input/local_unix.go +++ b/internal/client/input/local_unix.go @@ -99,10 +99,6 @@ func (c *LocalUnixInputClient) ReadMetadata(path string) (*MetadataStruct, error }, nil } -func (c *LocalUnixInputClient) ID(path string) string { - return fmt.Sprintf("local-unix://%s%s", c.path, path) -} - func (c *LocalUnixInputClient) GetReader(path string) (io.ReadCloser, error) { return os.Open(c.path + path) } |