syncacl

Documentation

Index

• Constants
• Variables
• type AclSyncProtocol
• type RequestFactory
  • func NewRequestFactory() RequestFactory
• type SyncAcl
  • func New() SyncAcl
• type SyncClient
  • func NewSyncClient(spaceId string, requestManager requestmanager.RequestManager, ...) SyncClient

Constants

const CName = "common.acl.syncacl"

Variables

var (
	ErrMessageIsRequest    = errors.New("message is request")
	ErrMessageIsNotRequest = errors.New("message is not request")
)

var (
	ErrSyncAclClosed = errors.New("sync acl is closed")
)

Types

type AclSyncProtocol

type AclSyncProtocol interface {
	HeadUpdate(ctx context.Context, senderId string, update *consensusproto.LogHeadUpdate) (request *consensusproto.LogSyncMessage, err error)
	FullSyncRequest(ctx context.Context, senderId string, request *consensusproto.LogFullSyncRequest) (response *consensusproto.LogSyncMessage, err error)
	FullSyncResponse(ctx context.Context, senderId string, response *consensusproto.LogFullSyncResponse) (err error)
}

type RequestFactory

type RequestFactory interface {
	CreateHeadUpdate(l list.AclList, added []*consensusproto.RawRecordWithId) (msg *consensusproto.LogSyncMessage)
	CreateFullSyncRequest(l list.AclList, theirHead string) (req *consensusproto.LogSyncMessage, err error)
	CreateFullSyncResponse(l list.AclList, theirHead string) (*consensusproto.LogSyncMessage, error)
}

func NewRequestFactory

func NewRequestFactory() RequestFactory

type SyncAcl

type SyncAcl interface {
	app.ComponentRunnable
	list.AclList
	syncobjectgetter.SyncObject
	SetHeadUpdater(updater headupdater.HeadUpdater)
	SyncWithPeer(ctx context.Context, peerId string) (err error)
}

func New

func New() SyncAcl

type SyncClient

type SyncClient interface {
	RequestFactory
	Broadcast(msg *consensusproto.LogSyncMessage)
	SendUpdate(peerId string, msg *consensusproto.LogSyncMessage) (err error)
	QueueRequest(peerId string, msg *consensusproto.LogSyncMessage) (err error)
	SendRequest(ctx context.Context, peerId string, msg *consensusproto.LogSyncMessage) (reply *spacesyncproto.ObjectSyncMessage, err error)
}

func NewSyncClient

func NewSyncClient(spaceId string, requestManager requestmanager.RequestManager, peerManager peermanager.PeerManager) SyncClient