replication

package
v0.0.0-...-6850833 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 18, 2024 License: LGPL-3.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var File_yamcs_protobuf_replication_replication_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type ReplicationInfo

type ReplicationInfo struct {
	Masters []*ReplicationMasterInfo `protobuf:"bytes,1,rep,name=masters" json:"masters,omitempty"`
	Slaves  []*ReplicationSlaveInfo  `protobuf:"bytes,2,rep,name=slaves" json:"slaves,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplicationInfo) Descriptor deprecated

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

Deprecated: Use ReplicationInfo.ProtoReflect.Descriptor instead.

func (*ReplicationInfo) GetMasters

func (x *ReplicationInfo) GetMasters() []*ReplicationMasterInfo

func (*ReplicationInfo) GetSlaves

func (x *ReplicationInfo) GetSlaves() []*ReplicationSlaveInfo

func (*ReplicationInfo) ProtoMessage

func (*ReplicationInfo) ProtoMessage()

func (*ReplicationInfo) ProtoReflect

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

func (*ReplicationInfo) Reset

func (x *ReplicationInfo) Reset()

func (*ReplicationInfo) String

func (x *ReplicationInfo) String() string

type ReplicationMasterInfo

type ReplicationMasterInfo struct {

	// Yamcs instance name
	Instance      *string  `protobuf:"bytes,1,opt,name=instance" json:"instance,omitempty"`
	Streams       []string `protobuf:"bytes,2,rep,name=streams" json:"streams,omitempty"`
	LocalAddress  *string  `protobuf:"bytes,3,opt,name=localAddress" json:"localAddress,omitempty"`
	RemoteAddress *string  `protobuf:"bytes,4,opt,name=remoteAddress" json:"remoteAddress,omitempty"`
	Push          *bool    `protobuf:"varint,5,opt,name=push" json:"push,omitempty"`
	PushTo        *string  `protobuf:"bytes,6,opt,name=pushTo" json:"pushTo,omitempty"`
	LocalTx       *int64   `protobuf:"varint,7,opt,name=localTx" json:"localTx,omitempty"`
	NextTx        *int64   `protobuf:"varint,8,opt,name=nextTx" json:"nextTx,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplicationMasterInfo) Descriptor deprecated

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

Deprecated: Use ReplicationMasterInfo.ProtoReflect.Descriptor instead.

func (*ReplicationMasterInfo) GetInstance

func (x *ReplicationMasterInfo) GetInstance() string

func (*ReplicationMasterInfo) GetLocalAddress

func (x *ReplicationMasterInfo) GetLocalAddress() string

func (*ReplicationMasterInfo) GetLocalTx

func (x *ReplicationMasterInfo) GetLocalTx() int64

func (*ReplicationMasterInfo) GetNextTx

func (x *ReplicationMasterInfo) GetNextTx() int64

func (*ReplicationMasterInfo) GetPush

func (x *ReplicationMasterInfo) GetPush() bool

func (*ReplicationMasterInfo) GetPushTo

func (x *ReplicationMasterInfo) GetPushTo() string

func (*ReplicationMasterInfo) GetRemoteAddress

func (x *ReplicationMasterInfo) GetRemoteAddress() string

func (*ReplicationMasterInfo) GetStreams

func (x *ReplicationMasterInfo) GetStreams() []string

func (*ReplicationMasterInfo) ProtoMessage

func (*ReplicationMasterInfo) ProtoMessage()

func (*ReplicationMasterInfo) ProtoReflect

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

func (*ReplicationMasterInfo) Reset

func (x *ReplicationMasterInfo) Reset()

func (*ReplicationMasterInfo) String

func (x *ReplicationMasterInfo) String() string

type ReplicationSlaveInfo

type ReplicationSlaveInfo struct {

	// Yamcs instance name
	Instance      *string  `protobuf:"bytes,1,opt,name=instance" json:"instance,omitempty"`
	Streams       []string `protobuf:"bytes,2,rep,name=streams" json:"streams,omitempty"`
	LocalAddress  *string  `protobuf:"bytes,3,opt,name=localAddress" json:"localAddress,omitempty"`
	RemoteAddress *string  `protobuf:"bytes,4,opt,name=remoteAddress" json:"remoteAddress,omitempty"`
	Push          *bool    `protobuf:"varint,5,opt,name=push" json:"push,omitempty"`
	PullFrom      *string  `protobuf:"bytes,6,opt,name=pullFrom" json:"pullFrom,omitempty"`
	Tx            *int64   `protobuf:"varint,7,opt,name=tx" json:"tx,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplicationSlaveInfo) Descriptor deprecated

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

Deprecated: Use ReplicationSlaveInfo.ProtoReflect.Descriptor instead.

func (*ReplicationSlaveInfo) GetInstance

func (x *ReplicationSlaveInfo) GetInstance() string

func (*ReplicationSlaveInfo) GetLocalAddress

func (x *ReplicationSlaveInfo) GetLocalAddress() string

func (*ReplicationSlaveInfo) GetPullFrom

func (x *ReplicationSlaveInfo) GetPullFrom() string

func (*ReplicationSlaveInfo) GetPush

func (x *ReplicationSlaveInfo) GetPush() bool

func (*ReplicationSlaveInfo) GetRemoteAddress

func (x *ReplicationSlaveInfo) GetRemoteAddress() string

func (*ReplicationSlaveInfo) GetStreams

func (x *ReplicationSlaveInfo) GetStreams() []string

func (*ReplicationSlaveInfo) GetTx

func (x *ReplicationSlaveInfo) GetTx() int64

func (*ReplicationSlaveInfo) ProtoMessage

func (*ReplicationSlaveInfo) ProtoMessage()

func (*ReplicationSlaveInfo) ProtoReflect

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

func (*ReplicationSlaveInfo) Reset

func (x *ReplicationSlaveInfo) Reset()

func (*ReplicationSlaveInfo) String

func (x *ReplicationSlaveInfo) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL