private

Documentation

Index

• Constants
• type SequenceOptions
  • func (v *SequenceOptions) Copy() *SequenceOptions
  • func (v *SequenceOptions) CopyAsInterface() interface{}
  • func (v *SequenceOptions) Equal(u *SequenceOptions) bool
  • func (v *SequenceOptions) IsValid() error
  • func (v *SequenceOptions) MarshalBinary() ([]byte, error)
  • func (v *SequenceOptions) MarshalJSON() ([]byte, error)
  • func (v *SequenceOptions) UnmarshalBinary(data []byte) error
  • func (v *SequenceOptions) UnmarshalBinaryFrom(rd io.Reader) error
  • func (v *SequenceOptions) UnmarshalJSON(data []byte) error
• type Sequencer

Constants

const ServiceTypeSequencer api.ServiceType = 0xF001

Types

type SequenceOptions

type SequenceOptions struct {
	NodeID p2p.PeerID `json:"nodeID,omitempty" form:"nodeID" query:"nodeID" validate:"required"`
	// contains filtered or unexported fields
}

func (*SequenceOptions) Copy

func (v *SequenceOptions) Copy() *SequenceOptions

func (*SequenceOptions) CopyAsInterface

func (v *SequenceOptions) CopyAsInterface() interface{}

func (*SequenceOptions) Equal

func (v *SequenceOptions) Equal(u *SequenceOptions) bool

func (*SequenceOptions) IsValid

func (v *SequenceOptions) IsValid() error

func (*SequenceOptions) MarshalBinary

func (v *SequenceOptions) MarshalBinary() ([]byte, error)

func (*SequenceOptions) MarshalJSON

func (v *SequenceOptions) MarshalJSON() ([]byte, error)

func (*SequenceOptions) UnmarshalBinary

func (v *SequenceOptions) UnmarshalBinary(data []byte) error

func (*SequenceOptions) UnmarshalBinaryFrom

func (v *SequenceOptions) UnmarshalBinaryFrom(rd io.Reader) error

func (*SequenceOptions) UnmarshalJSON

func (v *SequenceOptions) UnmarshalJSON(data []byte) error

type Sequencer

type Sequencer interface {
	Sequence(ctx context.Context, src, dst *url.URL, num uint64, opts SequenceOptions) (*api.MessageRecord[messaging.Message], error)
}