messages

package
v0.0.4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 8, 2023 License: MIT Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	RoomAttendantsResponseTypeJoined = RoomAttendantsResponseType{"joined"}
	RoomAttendantsResponseTypeLeft   = RoomAttendantsResponseType{"left"}
)
View Source 
var (
	BlobsCreateWantsProcedure = rpc.MustNewProcedure(
		rpc.MustNewProcedureName([]string{"blobs", "createWants"}),
		rpc.ProcedureTypeSource,
	)
)
View Source 
var (
	BlobsGetProcedure = rpc.MustNewProcedure(
		rpc.MustNewProcedureName([]string{"blobs", "get"}),
		rpc.ProcedureTypeSource,
	)
)
View Source 
var (
	CreateHistoryStreamProcedure = rpc.MustNewProcedure(
		rpc.MustNewProcedureName([]string{"createHistoryStream"}),
		rpc.ProcedureTypeSource,
	)
)
View Source 
var (
	EbtReplicateFormatClassic = EbtReplicateFormat{"classic"}
)
View Source 
var (
	EbtReplicateProcedure = rpc.MustNewProcedure(
		rpc.MustNewProcedureName([]string{"ebt", "replicate"}),
		rpc.ProcedureTypeDuplex,
	)
)
View Source 
var (
	InviteUseProcedure = rpc.MustNewProcedure(
		rpc.MustNewProcedureName([]string{"invite", "use"}),
		rpc.ProcedureTypeAsync,
	)
)
View Source 
var (
	RoomAttendantsProcedure = rpc.MustNewProcedure(
		rpc.MustNewProcedureName([]string{"room", "attendants"}),
		rpc.ProcedureTypeSource,
	)
)
View Source 
var (
	RoomListAliasesProcedure = rpc.MustNewProcedure(
		rpc.MustNewProcedureName([]string{"room", "listAliases"}),
		rpc.ProcedureTypeAsync,
	)
)
View Source 
var (
	RoomMetadataProcedure = rpc.MustNewProcedure(
		rpc.MustNewProcedureName([]string{"room", "metadata"}),
		rpc.ProcedureTypeAsync,
	)
)
View Source 
var (
	RoomRegisterAliasProcedure = rpc.MustNewProcedure(
		rpc.MustNewProcedureName([]string{"room", "registerAlias"}),
		rpc.ProcedureTypeAsync,
	)
)
View Source 
var (
	RoomRevokeAliasProcedure = rpc.MustNewProcedure(
		rpc.MustNewProcedureName([]string{"room", "revokeAlias"}),
		rpc.ProcedureTypeAsync,
	)
)
View Source 
var (
	TunnelConnectProcedure = rpc.MustNewProcedure(
		rpc.MustNewProcedureName([]string{"tunnel", "connect"}),
		rpc.ProcedureTypeDuplex,
	)
)

Functions

func NewBlobsCreateWants 

func NewBlobsCreateWants() (*rpc.Request, error)

func NewBlobsGet 

func NewBlobsGet(arguments BlobsGetArguments) (*rpc.Request, error)

func NewCreateHistoryStream 

func NewCreateHistoryStream(arguments CreateHistoryStreamArguments) (*rpc.Request, error)

func NewEbtReplicate 

func NewEbtReplicate(arguments EbtReplicateArguments) (*rpc.Request, error)

func NewInviteUse 

func NewInviteUse(arguments InviteUseArguments) (*rpc.Request, error)

func NewRoomAttendants 

func NewRoomAttendants() (*rpc.Request, error)

func NewRoomListAliases 

func NewRoomListAliases(arguments RoomListAliasesArguments) (*rpc.Request, error)

func NewRoomMetadata 

func NewRoomMetadata() (*rpc.Request, error)

func NewRoomRegisterAlias 

func NewRoomRegisterAlias(arguments RoomRegisterAliasArguments) (*rpc.Request, error)

func NewRoomRevokeAlias 

func NewRoomRevokeAlias(arguments RoomRevokeAliasArguments) (*rpc.Request, error)

func NewTunnelConnectToPortal 

func NewTunnelConnectToPortal(arguments TunnelConnectToPortalArguments) (*rpc.Request, error)

func NewTunnelConnectToTarget 

func NewTunnelConnectToTarget(arguments TunnelConnectToTargetArguments) (*rpc.Request, error)

Types

type BlobWithSizeOrWantDistance 

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

func MustNewBlobWithSize 

func MustNewBlobWithSize(id refs.Blob, size blobs.Size) BlobWithSizeOrWantDistance

func MustNewBlobWithWantDistance 

func MustNewBlobWithWantDistance(id refs.Blob, wantDistance blobs.WantDistance) BlobWithSizeOrWantDistance

func NewBlobWithSize 

func NewBlobWithSize(id refs.Blob, size blobs.Size) (BlobWithSizeOrWantDistance, error)

func NewBlobWithSizeOrWantDistance 

func NewBlobWithSizeOrWantDistance(id refs.Blob, sizeOrWantDistance blobs.SizeOrWantDistance) (BlobWithSizeOrWantDistance, error)

func NewBlobWithWantDistance 

func NewBlobWithWantDistance(id refs.Blob, wantDistance blobs.WantDistance) (BlobWithSizeOrWantDistance, error)

func (BlobWithSizeOrWantDistance) Id 

func (b BlobWithSizeOrWantDistance) Id() refs.Blob

func (BlobWithSizeOrWantDistance) SizeOrWantDistance 

func (b BlobWithSizeOrWantDistance) SizeOrWantDistance() blobs.SizeOrWantDistance

func (BlobWithSizeOrWantDistance) String 

func (b BlobWithSizeOrWantDistance) String() string

type BlobsCreateWantsResponse 

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

func NewBlobsCreateWantsResponse 

func NewBlobsCreateWantsResponse(id refs.Blob, sizeOrWantDistance blobs.SizeOrWantDistance) (BlobsCreateWantsResponse, error)

func NewBlobsCreateWantsResponseFromBytes 

func NewBlobsCreateWantsResponseFromBytes(b []byte) (BlobsCreateWantsResponse, error)

func (BlobsCreateWantsResponse) List 

func (resp BlobsCreateWantsResponse) List() []BlobWithSizeOrWantDistance

func (BlobsCreateWantsResponse) MarshalJSON 

func (resp BlobsCreateWantsResponse) MarshalJSON() ([]byte, error)

type BlobsGetArguments 

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

func NewBlobsGetArguments 

func NewBlobsGetArguments(hash refs.Blob, size, max *blobs.Size) (BlobsGetArguments, error)

func NewBlobsGetArgumentsFromBytes 

func NewBlobsGetArgumentsFromBytes(b []byte) (BlobsGetArguments, error)

func (BlobsGetArguments) Hash 

func (a BlobsGetArguments) Hash() refs.Blob

func (BlobsGetArguments) MarshalJSON 

func (a BlobsGetArguments) MarshalJSON() ([]byte, error)

func (BlobsGetArguments) Max 

func (a BlobsGetArguments) Max() (blobs.Size, bool)

func (BlobsGetArguments) Size 

func (a BlobsGetArguments) Size() (blobs.Size, bool)

type CreateHistoryStreamArguments 

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

func NewCreateHistoryStreamArguments 

func NewCreateHistoryStreamArguments(
	id refs.Feed,
	sequence *message.Sequence,
	limit *int,
	live *bool,
	old *bool,
	keys *bool,
) (CreateHistoryStreamArguments, error)

func NewCreateHistoryStreamArgumentsFromBytes 

func NewCreateHistoryStreamArgumentsFromBytes(b []byte) (CreateHistoryStreamArguments, error)

func (CreateHistoryStreamArguments) Id 

func (c CreateHistoryStreamArguments) Id() refs.Feed

func (CreateHistoryStreamArguments) Keys 

func (c CreateHistoryStreamArguments) Keys() bool

func (CreateHistoryStreamArguments) Limit 

func (c CreateHistoryStreamArguments) Limit() *int

func (CreateHistoryStreamArguments) Live 

func (c CreateHistoryStreamArguments) Live() bool

func (CreateHistoryStreamArguments) MarshalJSON 

func (c CreateHistoryStreamArguments) MarshalJSON() ([]byte, error)

func (CreateHistoryStreamArguments) Old 

func (c CreateHistoryStreamArguments) Old() bool

func (CreateHistoryStreamArguments) Sequence 

func (c CreateHistoryStreamArguments) Sequence() *message.Sequence

type CreateHistoryStreamResponse 

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

func NewCreateHistoryStreamResponse 

func NewCreateHistoryStreamResponse(
	key refs.Message,
	value message.RawMessage,
	timestamp time.Time,
) *CreateHistoryStreamResponse

func (CreateHistoryStreamResponse) MarshalJSON 

func (c CreateHistoryStreamResponse) MarshalJSON() ([]byte, error)

type EbtReplicateArguments 

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

func NewEbtReplicateArguments 

func NewEbtReplicateArguments(
	version int,
	format EbtReplicateFormat,
) (EbtReplicateArguments, error)

func NewEbtReplicateArgumentsFromBytes 

func NewEbtReplicateArgumentsFromBytes(b []byte) (EbtReplicateArguments, error)

func (EbtReplicateArguments) Format 

func (c EbtReplicateArguments) Format() EbtReplicateFormat

func (EbtReplicateArguments) MarshalJSON 

func (c EbtReplicateArguments) MarshalJSON() ([]byte, error)

func (EbtReplicateArguments) Version 

func (c EbtReplicateArguments) Version() int

type EbtReplicateFormat 

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

func (EbtReplicateFormat) IsZero 

func (f EbtReplicateFormat) IsZero() bool

type EbtReplicateNote 

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

func MustNewEbtReplicateNote 

func MustNewEbtReplicateNote(ref refs.Feed, receive, replicate bool, sequence int) EbtReplicateNote

func NewEbtReplicateNote 

func NewEbtReplicateNote(ref refs.Feed, receive, replicate bool, sequence int) (EbtReplicateNote, error)

func (EbtReplicateNote) Equal 

func (e EbtReplicateNote) Equal(o EbtReplicateNote) bool

func (EbtReplicateNote) IsZero 

func (e EbtReplicateNote) IsZero() bool

func (EbtReplicateNote) MarshalJSON 

func (e EbtReplicateNote) MarshalJSON() ([]byte, error)

func (EbtReplicateNote) Receive 

func (e EbtReplicateNote) Receive() bool

func (EbtReplicateNote) Ref 

func (e EbtReplicateNote) Ref() refs.Feed

func (EbtReplicateNote) Replicate 

func (e EbtReplicateNote) Replicate() bool

func (EbtReplicateNote) Sequence 

func (e EbtReplicateNote) Sequence() int

type EbtReplicateNotes 

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

func MustNewEbtReplicateNotes 

func MustNewEbtReplicateNotes(notes []EbtReplicateNote) EbtReplicateNotes

func NewEbtReplicateNotes 

func NewEbtReplicateNotes(notes []EbtReplicateNote) (EbtReplicateNotes, error)

func NewEbtReplicateNotesFromBytes 

func NewEbtReplicateNotesFromBytes(b []byte) (EbtReplicateNotes, error)

func (*EbtReplicateNotes) Empty 

func (n *EbtReplicateNotes) Empty() bool

func (*EbtReplicateNotes) MarshalJSON 

func (n *EbtReplicateNotes) MarshalJSON() ([]byte, error)

func (*EbtReplicateNotes) Notes 

func (n *EbtReplicateNotes) Notes() []EbtReplicateNote

type InviteUseArguments 

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

func NewInviteUseArguments 

func NewInviteUseArguments(feed refs.Identity) (InviteUseArguments, error)

func NewInviteUseArgumentsFromBytes 

func NewInviteUseArgumentsFromBytes(b []byte) (InviteUseArguments, error)

func (InviteUseArguments) MarshalJSON 

func (i InviteUseArguments) MarshalJSON() ([]byte, error)

type RoomAttendantsResponseJoinedOrLeft 

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

func NewRoomAttendantsResponseJoinedOrLeftFromBytes 

func NewRoomAttendantsResponseJoinedOrLeftFromBytes(b []byte) (RoomAttendantsResponseJoinedOrLeft, error)

func (RoomAttendantsResponseJoinedOrLeft) Id 

func (r RoomAttendantsResponseJoinedOrLeft) Id() refs.Identity

func (RoomAttendantsResponseJoinedOrLeft) Typ 

func (r RoomAttendantsResponseJoinedOrLeft) Typ() RoomAttendantsResponseType

type RoomAttendantsResponseState 

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

func NewRoomAttendantsResponseStateFromBytes 

func NewRoomAttendantsResponseStateFromBytes(b []byte) (RoomAttendantsResponseState, error)

func (RoomAttendantsResponseState) Ids 

func (r RoomAttendantsResponseState) Ids() []refs.Identity

type RoomAttendantsResponseType 

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

type RoomListAliasesArguments 

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

func NewRoomListAliasesArguments 

func NewRoomListAliasesArguments(
	identity refs.Identity,
) (RoomListAliasesArguments, error)

func (RoomListAliasesArguments) MarshalJSON 

func (i RoomListAliasesArguments) MarshalJSON() ([]byte, error)

type RoomListAliasesResponse 

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

func NewRoomListAliasesResponseFromBytes 

func NewRoomListAliasesResponseFromBytes(b []byte) (RoomListAliasesResponse, error)

func (RoomListAliasesResponse) Aliases 

func (r RoomListAliasesResponse) Aliases() []aliases.Alias

type RoomMetadataResponse 

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

func NewRoomMetadataResponse 

func NewRoomMetadataResponse(membership bool, ftrs features.Features) RoomMetadataResponse

func NewRoomMetadataResponseFromBytes 

func NewRoomMetadataResponseFromBytes(b []byte) (RoomMetadataResponse, error)

func (RoomMetadataResponse) Features 

func (r RoomMetadataResponse) Features() features.Features

func (RoomMetadataResponse) Membership 

func (r RoomMetadataResponse) Membership() bool

type RoomRegisterAliasArguments 

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

func NewRoomRegisterAliasArguments 

func NewRoomRegisterAliasArguments(
	alias aliases.Alias,
	signature aliases.RegistrationSignature,
) (RoomRegisterAliasArguments, error)

func (RoomRegisterAliasArguments) MarshalJSON 

func (i RoomRegisterAliasArguments) MarshalJSON() ([]byte, error)

type RoomRegisterAliasResponse 

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

func NewRoomRegisterAliasResponseFromBytes 

func NewRoomRegisterAliasResponseFromBytes(b []byte) (RoomRegisterAliasResponse, error)

func (RoomRegisterAliasResponse) AliasEndpointURL 

func (r RoomRegisterAliasResponse) AliasEndpointURL() aliases.AliasEndpointURL

type RoomRevokeAliasArguments 

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

func NewRoomRevokeAliasArguments 

func NewRoomRevokeAliasArguments(
	alias aliases.Alias,
) (RoomRevokeAliasArguments, error)

func (RoomRevokeAliasArguments) MarshalJSON 

func (i RoomRevokeAliasArguments) MarshalJSON() ([]byte, error)

type TunnelConnectToPortalArguments 

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

func NewTunnelConnectToPortalArguments 

func NewTunnelConnectToPortalArguments(
	portal refs.Identity,
	target refs.Identity,
) (TunnelConnectToPortalArguments, error)

func (TunnelConnectToPortalArguments) MarshalJSON 

func (i TunnelConnectToPortalArguments) MarshalJSON() ([]byte, error)

type TunnelConnectToTargetArguments 

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

func NewTunnelConnectToTargetArguments 

func NewTunnelConnectToTargetArguments(
	portal refs.Identity,
	target refs.Identity,
	origin refs.Identity,
) (TunnelConnectToTargetArguments, error)

func NewTunnelConnectToTargetArgumentsFromBytes 

func NewTunnelConnectToTargetArgumentsFromBytes(b []byte) (TunnelConnectToTargetArguments, error)

func (TunnelConnectToTargetArguments) MarshalJSON 

func (t TunnelConnectToTargetArguments) MarshalJSON() ([]byte, error)

func (TunnelConnectToTargetArguments) Origin 

func (t TunnelConnectToTargetArguments) Origin() refs.Identity

func (TunnelConnectToTargetArguments) Portal 

func (t TunnelConnectToTargetArguments) Portal() refs.Identity

func (TunnelConnectToTargetArguments) Target 

func (t TunnelConnectToTargetArguments) Target() refs.Identity

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.