encoder

type Base64Encoder ¶

type Base64Encoder struct{}

Base64Encoder adheres to the Encoder interface, utilizing the encoding/base64 encoding strategy for base64 encoding.

func NewBase64Encoder() *Base64Encoder

func (e *Base64Encoder) Decode(s string) ([]byte, error)

func (e *Base64Encoder) Encode(data []byte) (string, error)

type ContinuationTokenSerializer ¶ added in v1.8.0

type ContinuationTokenSerializer interface {
	// Serialize serializes the continuation token into a format readable by ReadChanges
	Serialize(ulid string, objType string) (token []byte, err error)

	// Deserialize deserializes the continuation token into a format readable by ReadChanges
	Deserialize(token string) (ulid string, objType string, err error)
}

func NewStringContinuationTokenSerializer() ContinuationTokenSerializer

type Encoder ¶

type Encoder interface {
	Decode(string) ([]byte, error)
	Encode([]byte) (string, error)
}

Encoder is an interface that defines methods for decoding and encoding data.

type NoopEncoder ¶ added in v0.1.5

type NoopEncoder struct{}

NoopEncoder is an implementation of the Encoder interface that performs no actual encoding or decoding.

func (e NoopEncoder) Decode(s string) ([]byte, error)

func (e NoopEncoder) Encode(data []byte) (string, error)

type StringContinuationTokenSerializer ¶ added in v1.8.0

type StringContinuationTokenSerializer struct{}

StringContinuationTokenSerializer is a ContinuationTokenSerializer that serializes the continuation token as a string.

func (ts *StringContinuationTokenSerializer) Deserialize(continuationToken string) (ulid string, objType string, err error)

func (ts *StringContinuationTokenSerializer) Serialize(ulid string, objType string) ([]byte, error)

type TokenEncoder ¶ added in v0.1.5

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

TokenEncoder combines an encrypter and an encoder to provide functionality for encoding and decoding tokens.

func NewTokenEncoder(encrypter encrypter.Encrypter, encoder Encoder) *TokenEncoder

func (e *TokenEncoder) Decode(s string) ([]byte, error)

func (e *TokenEncoder) Encode(data []byte) (string, error)