Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ReadFilerSignature ¶
func ReadFilerSignature(grpcDialOption grpc.DialOption, filer pb.ServerAddress) (filerSignature int32, readErr error)
Types ¶
type Replicator ¶
type Replicator struct {
// contains filtered or unexported fields
}
func NewReplicator ¶
func NewReplicator(sourceConfig util.Configuration, configPrefix string, dataSink sink.ReplicationSink) *Replicator
func (*Replicator) Replicate ¶
func (r *Replicator) Replicate(ctx context.Context, key string, message *filer_pb.EventNotification) error
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.