azuresink

Documentation

Index

• type AzureSink
  • func (g *AzureSink) CreateEntry(ctx context.Context, key string, entry *filer_pb.Entry) error
  • func (g *AzureSink) DeleteEntry(ctx context.Context, key string, isDirectory, deleteIncludeChunks bool) error
  • func (g *AzureSink) GetName() string
  • func (g *AzureSink) GetSinkToDirectory() string
  • func (g *AzureSink) Initialize(configuration util.Configuration) error
  • func (g *AzureSink) SetSourceFiler(s *source.FilerSource)
  • func (g *AzureSink) UpdateEntry(ctx context.Context, key string, oldEntry *filer_pb.Entry, ...) (foundExistingEntry bool, err error)

Types

type AzureSink

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

func (*AzureSink) CreateEntry

func (g *AzureSink) CreateEntry(ctx context.Context, key string, entry *filer_pb.Entry) error

func (*AzureSink) DeleteEntry

func (g *AzureSink) DeleteEntry(ctx context.Context, key string, isDirectory, deleteIncludeChunks bool) error

func (*AzureSink) GetName

func (g *AzureSink) GetName() string

func (*AzureSink) GetSinkToDirectory

func (g *AzureSink) GetSinkToDirectory() string

func (*AzureSink) Initialize

func (g *AzureSink) Initialize(configuration util.Configuration) error

func (*AzureSink) SetSourceFiler

func (g *AzureSink) SetSourceFiler(s *source.FilerSource)

func (*AzureSink) UpdateEntry

func (g *AzureSink) UpdateEntry(ctx context.Context, key string, oldEntry *filer_pb.Entry, newParentPath string, newEntry *filer_pb.Entry, deleteIncludeChunks bool) (foundExistingEntry bool, err error)