converter

Documentation

Index

• Variables
• func BytesToObject(snapshot []byte) (*json.Object, error)
• func FromChangePack(pbPack *api.ChangePack) (*change.Pack, error)
• func FromClient(pbClient *api.Client) (*types.Client, error)
• func FromClients(pbClients *api.Clients) ([]*types.Client, error)
• func FromDocEvent(docEvent *api.DocEvent) (*sync.DocEvent, error)
• func FromDocumentKeys(pbKeys []*api.DocumentKey) []*key.Key
• func FromEventType(pbDocEventType api.DocEventType) (types.DocEventType, error)
• func FromMetadataInfo(pbMetadata *api.Metadata) types.MetadataInfo
• func FromOperations(pbOps []*api.Operation) ([]operation.Operation, error)
• func ObjectToBytes(obj *json.Object) ([]byte, error)
• func ToChangePack(pack *change.Pack) (*api.ChangePack, error)
• func ToClient(client types.Client) *api.Client
• func ToClientsMap(clientsMap map[string][]types.Client) map[string]*api.Clients
• func ToDocEvent(docEvent sync.DocEvent) (*api.DocEvent, error)
• func ToDocEventType(eventType types.DocEventType) (api.DocEventType, error)
• func ToDocumentKeys(keys []*key.Key) []*api.DocumentKey
• func ToMetadataInfo(metadata types.MetadataInfo) *api.Metadata
• func ToOperations(operations []operation.Operation) ([]*api.Operation, error)

Variables

var (
	// ErrPackRequired is returned when an empty pack is passed.
	ErrPackRequired = errors.New("pack required")

	// ErrCheckpointRequired is returned when a pack with an empty checkpoint is
	// passed.
	ErrCheckpointRequired = errors.New("checkpoint required")

	// ErrUnsupportedOperation is returned when the given operation is not
	// supported yet.
	ErrUnsupportedOperation = errors.New("unsupported operation")

	// ErrUnsupportedElement is returned when the given element is not
	// supported yet.
	ErrUnsupportedElement = errors.New("unsupported element")

	// ErrUnsupportedEventType is returned when the given event type is not
	// supported yet.
	ErrUnsupportedEventType = errors.New("unsupported event type")

	// ErrUnsupportedValueType is returned when the given value type is not
	// supported yet.
	ErrUnsupportedValueType = errors.New("unsupported value type")

	// ErrUnsupportedCounterType is returned when the given counter type is not
	// supported yet.
	ErrUnsupportedCounterType = errors.New("unsupported counter type")
)

Functions

func BytesToObject

func BytesToObject(snapshot []byte) (*json.Object, error)

BytesToObject creates an Object from the given byte array.

func FromChangePack

func FromChangePack(pbPack *api.ChangePack) (*change.Pack, error)

FromChangePack converts the given Protobuf format to model format.

func FromClient

func FromClient(pbClient *api.Client) (*types.Client, error)

FromClient converts the given Protobuf format to model format.

func FromClients

func FromClients(pbClients *api.Clients) ([]*types.Client, error)

FromClients converts the given Protobuf format to model format.

func FromDocEvent

func FromDocEvent(docEvent *api.DocEvent) (*sync.DocEvent, error)

FromDocEvent converts the given Protobuf format to model format.

func FromDocumentKeys

func FromDocumentKeys(pbKeys []*api.DocumentKey) []*key.Key

FromDocumentKeys converts the given Protobuf format to model format.

func FromEventType

func FromEventType(pbDocEventType api.DocEventType) (types.DocEventType, error)

FromEventType converts the given Protobuf format to model format.

func FromMetadataInfo

func FromMetadataInfo(pbMetadata *api.Metadata) types.MetadataInfo

FromMetadataInfo converts the given Protobuf format to model format.

func FromOperations

func FromOperations(pbOps []*api.Operation) ([]operation.Operation, error)

FromOperations converts the given Protobuf format to model format.

func ObjectToBytes

func ObjectToBytes(obj *json.Object) ([]byte, error)

ObjectToBytes converts the given object to byte array.

func ToChangePack

func ToChangePack(pack *change.Pack) (*api.ChangePack, error)

ToChangePack converts the given model format to Protobuf format.

func ToClient

func ToClient(client types.Client) *api.Client

ToClient converts the given model to Protobuf format.

func ToClientsMap

func ToClientsMap(clientsMap map[string][]types.Client) map[string]*api.Clients

ToClientsMap converts the given model to Protobuf format.

func ToDocEvent

func ToDocEvent(docEvent sync.DocEvent) (*api.DocEvent, error)

ToDocEvent converts the given model to Protobuf format.

func ToDocEventType

func ToDocEventType(eventType types.DocEventType) (api.DocEventType, error)

ToDocEventType converts the given model format to Protobuf format.

func ToDocumentKeys

func ToDocumentKeys(keys []*key.Key) []*api.DocumentKey

ToDocumentKeys converts the given model format to Protobuf format.

func ToMetadataInfo

func ToMetadataInfo(metadata types.MetadataInfo) *api.Metadata

ToMetadataInfo converts the given model to Protobuf format.

func ToOperations

func ToOperations(operations []operation.Operation) ([]*api.Operation, error)

ToOperations converts the given model format to Protobuf format.