bb_replicator

Documentation

Index

• Variables
• type ApplicationConfiguration
  • func (*ApplicationConfiguration) Descriptor() ([]byte, []int)
  • func (x *ApplicationConfiguration) GetGlobal() *global.Configuration
  • func (x *ApplicationConfiguration) GetGrpcServers() []*grpc.ServerConfiguration
  • func (x *ApplicationConfiguration) GetMaximumMessageSizeBytes() int64
  • func (x *ApplicationConfiguration) GetReplicator() *blobstore.BlobReplicatorConfiguration
  • func (x *ApplicationConfiguration) GetSink() *blobstore.BlobAccessConfiguration
  • func (x *ApplicationConfiguration) GetSource() *blobstore.BlobAccessConfiguration
  • func (*ApplicationConfiguration) ProtoMessage()
  • func (x *ApplicationConfiguration) ProtoReflect() protoreflect.Message
  • func (x *ApplicationConfiguration) Reset()
  • func (x *ApplicationConfiguration) String() string

Variables

var File_pkg_proto_configuration_bb_replicator_bb_replicator_proto protoreflect.FileDescriptor

Types

type ApplicationConfiguration

type ApplicationConfiguration struct {
	GrpcServers             []*grpc.ServerConfiguration            `protobuf:"bytes,2,rep,name=grpc_servers,json=grpcServers,proto3" json:"grpc_servers,omitempty"`
	Source                  *blobstore.BlobAccessConfiguration     `protobuf:"bytes,3,opt,name=source,proto3" json:"source,omitempty"`
	Sink                    *blobstore.BlobAccessConfiguration     `protobuf:"bytes,4,opt,name=sink,proto3" json:"sink,omitempty"`
	Replicator              *blobstore.BlobReplicatorConfiguration `protobuf:"bytes,5,opt,name=replicator,proto3" json:"replicator,omitempty"`
	MaximumMessageSizeBytes int64                                  `` /* 135-byte string literal not displayed */
	Global                  *global.Configuration                  `protobuf:"bytes,7,opt,name=global,proto3" json:"global,omitempty"`
	// contains filtered or unexported fields
}

func (*ApplicationConfiguration) Descriptor

func (*ApplicationConfiguration) Descriptor() ([]byte, []int)

Deprecated: Use ApplicationConfiguration.ProtoReflect.Descriptor instead.

func (*ApplicationConfiguration) GetGlobal

func (x *ApplicationConfiguration) GetGlobal() *global.Configuration

func (*ApplicationConfiguration) GetGrpcServers

func (x *ApplicationConfiguration) GetGrpcServers() []*grpc.ServerConfiguration

func (*ApplicationConfiguration) GetMaximumMessageSizeBytes

func (x *ApplicationConfiguration) GetMaximumMessageSizeBytes() int64

func (*ApplicationConfiguration) GetReplicator

func (x *ApplicationConfiguration) GetReplicator() *blobstore.BlobReplicatorConfiguration

func (*ApplicationConfiguration) GetSink

func (x *ApplicationConfiguration) GetSink() *blobstore.BlobAccessConfiguration

func (*ApplicationConfiguration) GetSource

func (x *ApplicationConfiguration) GetSource() *blobstore.BlobAccessConfiguration

func (*ApplicationConfiguration) ProtoMessage

func (*ApplicationConfiguration) ProtoMessage()

func (*ApplicationConfiguration) ProtoReflect

func (x *ApplicationConfiguration) ProtoReflect() protoreflect.Message

func (*ApplicationConfiguration) Reset

func (x *ApplicationConfiguration) Reset()

func (*ApplicationConfiguration) String

func (x *ApplicationConfiguration) String() string