repl

type DataType uint8

type JoinRequest struct {
	Host         string `json:"host" valid:"ascii,required"`
	Port         int    `json:"port" valid:"range(1|65535),required"`
	ServerId     uint16 `json:"serverId" valid:"range(0|65535),required"`
	WebHookToken string `json:"webHookToken" valid:"required"`
	SentBy       string `json:"sentBy" valid:"required"`
	Domain       string `json:"domain" valid:"required"`
	CreatedTime  int64  `json:"createdTime"`
	RequestId    string `json:"requestId" valid:"required"` // this is for correlation during approval phase
	PeerHost     string // no need to send to the peer
	PeerPort     int    // no need to send to the peer
}

type JoinResponse struct {
	PeerServerId     uint16            `json:"peerServerId" valid:"range(0|65535),required"`
	ApprovedBy       string            `json:"approvedBy" valid:"required"`
	PeerWebHookToken string            `json:"peerWebHookToken" valid:"required"`
	RequestId        string            `json:"requestId" valid:"required"` // this is for correlation during approval phase
	PeerView         []ReplicationPeer `json:"peerView"`
}

type ReplProviderSilo struct {
	// contains filtered or unexported fields
}

type ReplSilo struct {
	WebHookToken string // webhook token of this server
	// contains filtered or unexported fields
}

type ReplicationEvent struct {
	Version          string
	DomainCode       string
	Type             DataType
	Data             []byte
	CreatedRes       *base.Resource
	PatchIfMatch     string
	PatchRid         string
	RtName           string
	Rid              string
	ResToReplace     *base.Resource
	NewSession       *base.RbacSession
	SsoSession       bool
	RevokedSessionId string
	DeletedSessionId string
	NewPassword      string
	HashAlgo         string
	NewDomainName    string
	Cloning          bool // flag to indicate that this was generated as part of clone operation
}

type ReplicationPeer struct {
	ServerId           uint16            `json:"serverId"`
	BaseUrl            string            `json:"baseUrl"`
	EventsUrl          *url.URL          `json:"-"`
	WebHookToken       string            `json:"-"`
	ApprovedBy         string            `json:"approvedBy"`
	Domain             string            `json:"domain"`
	CreatedTime        int64             `json:"createdTime"`
	LastVersions       map[string]string `json:"lastVersions"` // a map of domain code and the associated event version
	PendingVersions    map[string]string `json:"-"`            // a map of domain code and the associated LATEST event version that was NOT sent yet due to backlog processing
	LastReqSentTime    int64             `json:"lastReqSentTime"`
	LastReqFailureTime int64             `json:"lastReqFailureTime"`
	// contains filtered or unexported fields
}