Documentation ¶
Index ¶
- func Mount(mountPoint string) error
- func NewConsumer(cc ClusterConfig) (*cluster.Consumer, error)
- func Topics(brokers []string) ([]string, error)
- type ClusterConfig
- type ClusterPipe
- func (kp *ClusterPipe) Attr(ctx context.Context, a *fuse.Attr) error
- func (kp *ClusterPipe) Create(ctx context.Context, req *fuse.CreateRequest, resp *fuse.CreateResponse) (fs.Node, fs.Handle, error)
- func (kp *ClusterPipe) Open(ctx context.Context, req *fuse.OpenRequest, resp *fuse.OpenResponse) (fs.Handle, error)
- func (kp *ClusterPipe) Read(ctx context.Context, req *fuse.ReadRequest, resp *fuse.ReadResponse) error
- func (kp *ClusterPipe) Release(ctx context.Context, req *fuse.ReleaseRequest) error
- func (kp *ClusterPipe) Write(ctx context.Context, req *fuse.WriteRequest, resp *fuse.WriteResponse) error
- type KDir
- type KFS
- type KafkaConfig
- type Producer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewConsumer ¶
func NewConsumer(cc ClusterConfig) (*cluster.Consumer, error)
Types ¶
type ClusterConfig ¶
type ClusterConfig struct { KafkaConfig Name string `json:"name"` }
type ClusterPipe ¶
type ClusterPipe struct { Brokers []string Topic string Cluster string FileName string Consumer *cluster.Consumer Producer *Producer }
func (*ClusterPipe) Create ¶
func (kp *ClusterPipe) Create(ctx context.Context, req *fuse.CreateRequest, resp *fuse.CreateResponse) (fs.Node, fs.Handle, error)
func (*ClusterPipe) Open ¶
func (kp *ClusterPipe) Open(ctx context.Context, req *fuse.OpenRequest, resp *fuse.OpenResponse) (fs.Handle, error)
func (*ClusterPipe) Read ¶
func (kp *ClusterPipe) Read(ctx context.Context, req *fuse.ReadRequest, resp *fuse.ReadResponse) error
This provides 3 reading reading strategies for the cluster. reader - This is just writing raw messages out messages - provides binary provides a single bit errors - stream of error messages
func (*ClusterPipe) Release ¶
func (kp *ClusterPipe) Release(ctx context.Context, req *fuse.ReleaseRequest) error
func (*ClusterPipe) Write ¶
func (kp *ClusterPipe) Write(ctx context.Context, req *fuse.WriteRequest, resp *fuse.WriteResponse) error
type KDir ¶
type KafkaConfig ¶
Click to show internal directories.
Click to hide internal directories.