types

Documentation

Index

• Variables
• func IsAuthMethod(method string) bool
• type AccessAttribute
• type AccessInfo
• type AuthWebhookRequest
  • func NewAuthWebhookRequest(reader io.Reader) (*AuthWebhookRequest, error)
• type AuthWebhookResponse
  • func NewAuthWebhookResponse(reader io.Reader) (*AuthWebhookResponse, error)
  • func (r *AuthWebhookResponse) Write(writer io.Writer) (int, error)
• type ChangeSummary
• type Client
  • func NewClient(encoded []byte) (*Client, error)
  • func (c *Client) Marshal() (string, error)
• type DocEventType
• type DocumentSummary
• type ID
  • func IDFromActorID(actorID *time.ActorID) ID
  • func IDFromBytes(bytes []byte) ID
  • func (id *ID) Bytes() ([]byte, error)
  • func (id *ID) String() string
  • func (id *ID) ToActorID() (*time.ActorID, error)
  • func (id *ID) Validate() error
• type Method
  • func AuthMethods() []Method
• type Paging
• type Presence
• type PresenceInfo
  • func (i *PresenceInfo) Update(info PresenceInfo) bool
• type Project
  • func (p *Project) RequireAuth(method Method) bool
• type VerbType

Variables

var (
	// ErrInvalidWebhookRequest is returned when the given webhook request is not valid.
	ErrInvalidWebhookRequest = errors.New("invalid authorization webhook request")

	// ErrInvalidWebhookResponse is returned when the given webhook response is not valid.
	ErrInvalidWebhookResponse = errors.New("invalid authorization webhook response")
)

var (
	// ErrInvalidID is returned when the given ID is not ObjectID.
	ErrInvalidID = errors.New("invalid ID")
)

Functions

func IsAuthMethod

func IsAuthMethod(method string) bool

IsAuthMethod returns whether the given method can be used for authorization.

Types

type AccessAttribute

type AccessAttribute struct {
	Key  string   `json:"key"`
	Verb VerbType `json:"verb"`
}

AccessAttribute represents an access attribute.

type AccessInfo

type AccessInfo struct {
	Method     Method
	Attributes []AccessAttribute
}

AccessInfo represents an access information.

type AuthWebhookRequest

type AuthWebhookRequest struct {
	Token      string            `json:"token"`
	Method     Method            `json:"method"`
	Attributes []AccessAttribute `json:"attributes"`
}

AuthWebhookRequest represents the request of authentication webhook.

func NewAuthWebhookRequest

func NewAuthWebhookRequest(reader io.Reader) (*AuthWebhookRequest, error)

NewAuthWebhookRequest creates a new instance of AuthWebhookRequest.

type AuthWebhookResponse

type AuthWebhookResponse struct {
	Allowed bool   `json:"allowed"`
	Reason  string `json:"reason"`
}

AuthWebhookResponse represents the response of authentication webhook.

func NewAuthWebhookResponse

func NewAuthWebhookResponse(reader io.Reader) (*AuthWebhookResponse, error)

NewAuthWebhookResponse creates a new instance of AuthWebhookResponse.

func (*AuthWebhookResponse) Write

func (r *AuthWebhookResponse) Write(writer io.Writer) (int, error)

Write writes this response to the given writer.

type ChangeSummary

type ChangeSummary struct {
	// ID is the unique identifier of the change.
	ID change.ID

	// Message is the message of the change.
	Message string

	// Snapshot is the snapshot of the document.
	Snapshot string
}

ChangeSummary represents a summary of change.

type Client

type Client struct {
	ID           *time.ActorID
	PresenceInfo PresenceInfo
}

Client represents the Client that communicates with the Server.

func NewClient

func NewClient(encoded []byte) (*Client, error)

NewClient creates a new Client from the given JSON.

func (*Client) Marshal

func (c *Client) Marshal() (string, error)

Marshal serializes the Client to JSON.

type DocEventType

type DocEventType string

DocEventType represents the event that the Server delivers to the client.

const (
	// DocumentsChangedEvent is an event indicating that documents are being
	// modified by a change.
	DocumentsChangedEvent DocEventType = "documents-changed"

	// DocumentsWatchedEvent is an event that occurs when documents are watched
	// by other clients.
	DocumentsWatchedEvent DocEventType = "documents-watched"

	// DocumentsUnwatchedEvent is an event that occurs when documents are
	// unwatched by other clients.
	DocumentsUnwatchedEvent DocEventType = "documents-unwatched"

	// PresenceChangedEvent is an event indicating that presence is changed.
	PresenceChangedEvent DocEventType = "presence-changed"
)

type DocumentSummary

type DocumentSummary struct {
	// ID is the unique identifier of the change.
	ID ID

	// Key is the key of the document.
	Key key.Key

	// CreatedAt is the time when the document is created.
	CreatedAt time.Time

	// AccessedAt is the time when the document is accessed.
	AccessedAt time.Time

	// UpdatedAt is the time when the document is updated.
	UpdatedAt time.Time

	// Snapshot is the string representation of the document.
	Snapshot string
}

DocumentSummary represents a summary of change.

type ID

type ID string

ID represents ID of entity.

func IDFromActorID

func IDFromActorID(actorID *time.ActorID) ID

IDFromActorID returns ID represented by the encoded hexadecimal string from actor ID.

func IDFromBytes

func IDFromBytes(bytes []byte) ID

IDFromBytes returns ID represented by the encoded hexadecimal string from bytes.

func (*ID) Bytes

func (id *ID) Bytes() ([]byte, error)

Bytes returns bytes of decoded hexadecimal string representation of this ID.

func (*ID) String

func (id *ID) String() string

String returns a string representation of this ID.

func (*ID) ToActorID

func (id *ID) ToActorID() (*time.ActorID, error)

ToActorID returns ActorID from this ID.

func (*ID) Validate

func (id *ID) Validate() error

Validate returns error if this ID is invalid.

type Method

type Method string

Method represents a method name of RPC.

const (
	ActivateClient   Method = "ActivateClient"
	DeactivateClient Method = "DeactivateClient"
	AttachDocument   Method = "AttachDocument"
	DetachDocument   Method = "DetachDocument"
	PushPull         Method = "PushPull"
	WatchDocuments   Method = "WatchDocuments"
	ListChanges      Method = "ListChangeSummaries"
)

Belows are the names of RPCs.

func AuthMethods

func AuthMethods() []Method

AuthMethods returns a slice of methods that can be used for authorization.

type Paging

type Paging struct {
	PreviousID ID
	PageSize   int
	IsForward  bool
}

Paging is the paging information for the document.

type Presence

type Presence map[string]string

Presence represents custom presence that can be defined in the client.

type PresenceInfo

type PresenceInfo struct {
	Clock    int32
	Presence Presence
}

PresenceInfo is a presence information with logical clock.

func (*PresenceInfo) Update

func (i *PresenceInfo) Update(info PresenceInfo) bool

Update updates the given presence information with the given clock.

type Project

type Project struct {
	// ID is the unique ID of the project.
	ID ID `json:"id"`

	// Name is the name of this project.
	Name string `json:"name"`

	// PublicKey is the API key of this project.
	PublicKey string `json:"public_key"`

	// SecretKey is the secret key of this project.
	SecretKey string `json:"secret_key"`

	// AuthWebhookURL is the url of the authorization webhook.
	AuthWebhookURL string `json:"auth_webhook_url"`

	// AuthWebhookMethods is the methods that run the authorization webhook.
	AuthWebhookMethods []string `json:"auth_webhook_methods"`

	// CreatedAt is the time when the project was created.
	CreatedAt time.Time `json:"created_at"`
}

Project is a project that consists of multiple documents and clients. It allows developers to work on the same cluster.

func (*Project) RequireAuth

func (p *Project) RequireAuth(method Method) bool

RequireAuth returns whether the given method requires authorization.

type VerbType

type VerbType string

VerbType represents an action taken on the document.

const (

	// Read represents the case of only reading the given document.
	Read VerbType = "r"

	// ReadWrite represents the case of reading and writing the given document.
	ReadWrite VerbType = "rw"
)