schema

package
v1.1.0-alpha-4 Latest Latest
Warning

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

 Go to latest Published: Jun 16, 2017 License: Apache-2.0 Imports: 3 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	OpWrite         = 1
	OpWriteZeroesAt = 2
)

Block operation

View Source 
const Command_TypeID = 0xdbe14b5e7e7c6009

Command_TypeID is the unique identifier for the type Command.

View Source 
const HandshakeRequest_TypeID = 0xe0d4e6d68fa24ac0

HandshakeRequest_TypeID is the unique identifier for the type HandshakeRequest.

View Source 
const HandshakeResponse_TypeID = 0xee959a7d96c96641

HandshakeResponse_TypeID is the unique identifier for the type HandshakeResponse.

View Source 
const TlogAggregation_TypeID = 0xe46ab5b4b619e094

TlogAggregation_TypeID is the unique identifier for the type TlogAggregation.

View Source 
const TlogBlock_TypeID = 0x8cf178de3c82d431

TlogBlock_TypeID is the unique identifier for the type TlogBlock.

View Source 
const TlogResponse_TypeID = 0x98d11ae1c78a24d9

TlogResponse_TypeID is the unique identifier for the type TlogResponse.

Variables

This section is empty.

Functions

func CopyBlock 

func CopyBlock(dst, src *TlogBlock) error

CopyBlock copies content of block 'src' to 'dst'

func RawServerHandshakeLen 

func RawServerHandshakeLen() int

RawServerHandshakeLen returns length of raw Handshake packet

func RawTlogRespLen 

func RawTlogRespLen(numSeq int) int

RawTlogRespLen returns length of raw TlogResponse packet

Types

type Command 

type Command struct{ capnp.Struct }

func NewCommand 

func NewCommand(s *capnp.Segment) (Command, error)

func NewRootCommand 

func NewRootCommand(s *capnp.Segment) (Command, error)

func ReadRootCommand 

func ReadRootCommand(msg *capnp.Message) (Command, error)

func (Command) Sequence 

func (s Command) Sequence() uint64

func (Command) SetSequence 

func (s Command) SetSequence(v uint64)

func (Command) SetType 

func (s Command) SetType(v uint8)

func (Command) String 

func (s Command) String() string

func (Command) Type 

func (s Command) Type() uint8

type Command_List 

type Command_List struct{ capnp.List }

Command_List is a list of Command.

func NewCommand_List 

func NewCommand_List(s *capnp.Segment, sz int32) (Command_List, error)

NewCommand creates a new list of Command.

func (Command_List) At 

func (s Command_List) At(i int) Command

func (Command_List) Set 

func (s Command_List) Set(i int, v Command) error

type Command_Promise 

type Command_Promise struct{ *capnp.Pipeline }

Command_Promise is a wrapper for a Command promised by a client call.

func (Command_Promise) Struct 

func (p Command_Promise) Struct() (Command, error)

type HandshakeRequest 

type HandshakeRequest struct{ capnp.Struct }

func NewHandshakeRequest 

func NewHandshakeRequest(s *capnp.Segment) (HandshakeRequest, error)

func NewRootHandshakeRequest 

func NewRootHandshakeRequest(s *capnp.Segment) (HandshakeRequest, error)

func ReadRootHandshakeRequest 

func ReadRootHandshakeRequest(msg *capnp.Message) (HandshakeRequest, error)

func (HandshakeRequest) FirstSequence 

func (s HandshakeRequest) FirstSequence() uint64

func (HandshakeRequest) HasVdiskID 

func (s HandshakeRequest) HasVdiskID() bool

func (HandshakeRequest) ResetFirstSequence 

func (s HandshakeRequest) ResetFirstSequence() bool

func (HandshakeRequest) SetFirstSequence 

func (s HandshakeRequest) SetFirstSequence(v uint64)

func (HandshakeRequest) SetResetFirstSequence 

func (s HandshakeRequest) SetResetFirstSequence(v bool)

func (HandshakeRequest) SetVdiskID 

func (s HandshakeRequest) SetVdiskID(v string) error

func (HandshakeRequest) SetVersion 

func (s HandshakeRequest) SetVersion(v uint32)

func (HandshakeRequest) String 

func (s HandshakeRequest) String() string

func (HandshakeRequest) VdiskID 

func (s HandshakeRequest) VdiskID() (string, error)

func (HandshakeRequest) VdiskIDBytes 

func (s HandshakeRequest) VdiskIDBytes() ([]byte, error)

func (HandshakeRequest) Version 

func (s HandshakeRequest) Version() uint32

type HandshakeRequest_List 

type HandshakeRequest_List struct{ capnp.List }

HandshakeRequest_List is a list of HandshakeRequest.

func NewHandshakeRequest_List 

func NewHandshakeRequest_List(s *capnp.Segment, sz int32) (HandshakeRequest_List, error)

NewHandshakeRequest creates a new list of HandshakeRequest.

func (HandshakeRequest_List) At 

func (s HandshakeRequest_List) At(i int) HandshakeRequest

func (HandshakeRequest_List) Set 

func (s HandshakeRequest_List) Set(i int, v HandshakeRequest) error

type HandshakeRequest_Promise 

type HandshakeRequest_Promise struct{ *capnp.Pipeline }

HandshakeRequest_Promise is a wrapper for a HandshakeRequest promised by a client call.

func (HandshakeRequest_Promise) Struct 

func (p HandshakeRequest_Promise) Struct() (HandshakeRequest, error)

type HandshakeResponse 

type HandshakeResponse struct{ capnp.Struct }

func NewHandshakeResponse 

func NewHandshakeResponse(s *capnp.Segment) (HandshakeResponse, error)

func NewRootHandshakeResponse 

func NewRootHandshakeResponse(s *capnp.Segment) (HandshakeResponse, error)

func ReadRootHandshakeResponse 

func ReadRootHandshakeResponse(msg *capnp.Message) (HandshakeResponse, error)

func (HandshakeResponse) SetStatus 

func (s HandshakeResponse) SetStatus(v int8)

func (HandshakeResponse) SetVersion 

func (s HandshakeResponse) SetVersion(v uint32)

func (HandshakeResponse) Status 

func (s HandshakeResponse) Status() int8

func (HandshakeResponse) String 

func (s HandshakeResponse) String() string

func (HandshakeResponse) Version 

func (s HandshakeResponse) Version() uint32

type HandshakeResponse_List 

type HandshakeResponse_List struct{ capnp.List }

HandshakeResponse_List is a list of HandshakeResponse.

func NewHandshakeResponse_List 

func NewHandshakeResponse_List(s *capnp.Segment, sz int32) (HandshakeResponse_List, error)

NewHandshakeResponse creates a new list of HandshakeResponse.

func (HandshakeResponse_List) At 

func (s HandshakeResponse_List) At(i int) HandshakeResponse

func (HandshakeResponse_List) Set 

func (s HandshakeResponse_List) Set(i int, v HandshakeResponse) error

type HandshakeResponse_Promise 

type HandshakeResponse_Promise struct{ *capnp.Pipeline }

HandshakeResponse_Promise is a wrapper for a HandshakeResponse promised by a client call.

func (HandshakeResponse_Promise) Struct 

func (p HandshakeResponse_Promise) Struct() (HandshakeResponse, error)

type TlogAggregation 

type TlogAggregation struct{ capnp.Struct }

func NewRootTlogAggregation 

func NewRootTlogAggregation(s *capnp.Segment) (TlogAggregation, error)

func NewTlogAggregation 

func NewTlogAggregation(s *capnp.Segment) (TlogAggregation, error)

func ReadRootTlogAggregation 

func ReadRootTlogAggregation(msg *capnp.Message) (TlogAggregation, error)

func (TlogAggregation) Blocks 

func (s TlogAggregation) Blocks() (TlogBlock_List, error)

func (TlogAggregation) HasBlocks 

func (s TlogAggregation) HasBlocks() bool

func (TlogAggregation) HasName 

func (s TlogAggregation) HasName() bool

func (TlogAggregation) HasPrev 

func (s TlogAggregation) HasPrev() bool

func (TlogAggregation) HasVdiskID 

func (s TlogAggregation) HasVdiskID() bool

func (TlogAggregation) Name 

func (s TlogAggregation) Name() (string, error)

func (TlogAggregation) NameBytes 

func (s TlogAggregation) NameBytes() ([]byte, error)

func (TlogAggregation) NewBlocks 

func (s TlogAggregation) NewBlocks(n int32) (TlogBlock_List, error)

NewBlocks sets the blocks field to a newly allocated TlogBlock_List, preferring placement in s's segment.

func (TlogAggregation) Prev 

func (s TlogAggregation) Prev() ([]byte, error)

func (TlogAggregation) SetBlocks 

func (s TlogAggregation) SetBlocks(v TlogBlock_List) error

func (TlogAggregation) SetName 

func (s TlogAggregation) SetName(v string) error

func (TlogAggregation) SetPrev 

func (s TlogAggregation) SetPrev(v []byte) error

func (TlogAggregation) SetSize 

func (s TlogAggregation) SetSize(v uint64)

func (TlogAggregation) SetTimestamp 

func (s TlogAggregation) SetTimestamp(v uint64)

func (TlogAggregation) SetVdiskID 

func (s TlogAggregation) SetVdiskID(v string) error

func (TlogAggregation) Size 

func (s TlogAggregation) Size() uint64

func (TlogAggregation) String 

func (s TlogAggregation) String() string

func (TlogAggregation) Timestamp 

func (s TlogAggregation) Timestamp() uint64

func (TlogAggregation) VdiskID 

func (s TlogAggregation) VdiskID() (string, error)

func (TlogAggregation) VdiskIDBytes 

func (s TlogAggregation) VdiskIDBytes() ([]byte, error)

type TlogAggregation_List 

type TlogAggregation_List struct{ capnp.List }

TlogAggregation_List is a list of TlogAggregation.

func NewTlogAggregation_List 

func NewTlogAggregation_List(s *capnp.Segment, sz int32) (TlogAggregation_List, error)

NewTlogAggregation creates a new list of TlogAggregation.

func (TlogAggregation_List) At 

func (s TlogAggregation_List) At(i int) TlogAggregation

func (TlogAggregation_List) Set 

func (s TlogAggregation_List) Set(i int, v TlogAggregation) error

type TlogAggregation_Promise 

type TlogAggregation_Promise struct{ *capnp.Pipeline }

TlogAggregation_Promise is a wrapper for a TlogAggregation promised by a client call.

func (TlogAggregation_Promise) Struct 

func (p TlogAggregation_Promise) Struct() (TlogAggregation, error)

type TlogBlock 

type TlogBlock struct{ capnp.Struct }

func NewRootTlogBlock 

func NewRootTlogBlock(s *capnp.Segment) (TlogBlock, error)

func NewTlogBlock 

func NewTlogBlock(s *capnp.Segment) (TlogBlock, error)

func ReadRootTlogBlock 

func ReadRootTlogBlock(msg *capnp.Message) (TlogBlock, error)

func (TlogBlock) Data 

func (s TlogBlock) Data() ([]byte, error)

func (TlogBlock) HasData 

func (s TlogBlock) HasData() bool

func (TlogBlock) HasHash 

func (s TlogBlock) HasHash() bool

func (TlogBlock) Hash 

func (s TlogBlock) Hash() ([]byte, error)

func (TlogBlock) Offset 

func (s TlogBlock) Offset() uint64

func (TlogBlock) Operation 

func (s TlogBlock) Operation() uint8

func (TlogBlock) Sequence 

func (s TlogBlock) Sequence() uint64

func (TlogBlock) SetData 

func (s TlogBlock) SetData(v []byte) error

func (TlogBlock) SetHash 

func (s TlogBlock) SetHash(v []byte) error

func (TlogBlock) SetOffset 

func (s TlogBlock) SetOffset(v uint64)

func (TlogBlock) SetOperation 

func (s TlogBlock) SetOperation(v uint8)

func (TlogBlock) SetSequence 

func (s TlogBlock) SetSequence(v uint64)

func (TlogBlock) SetSize 

func (s TlogBlock) SetSize(v uint64)

func (TlogBlock) SetTimestamp 

func (s TlogBlock) SetTimestamp(v uint64)

func (TlogBlock) Size 

func (s TlogBlock) Size() uint64

func (TlogBlock) String 

func (s TlogBlock) String() string

func (TlogBlock) Timestamp 

func (s TlogBlock) Timestamp() uint64

type TlogBlock_List 

type TlogBlock_List struct{ capnp.List }

TlogBlock_List is a list of TlogBlock.

func NewTlogBlock_List 

func NewTlogBlock_List(s *capnp.Segment, sz int32) (TlogBlock_List, error)

NewTlogBlock creates a new list of TlogBlock.

func (TlogBlock_List) At 

func (s TlogBlock_List) At(i int) TlogBlock

func (TlogBlock_List) Set 

func (s TlogBlock_List) Set(i int, v TlogBlock) error

type TlogBlock_Promise 

type TlogBlock_Promise struct{ *capnp.Pipeline }

TlogBlock_Promise is a wrapper for a TlogBlock promised by a client call.

func (TlogBlock_Promise) Struct 

func (p TlogBlock_Promise) Struct() (TlogBlock, error)

type TlogResponse 

type TlogResponse struct{ capnp.Struct }

func NewRootTlogResponse 

func NewRootTlogResponse(s *capnp.Segment) (TlogResponse, error)

func NewTlogResponse 

func NewTlogResponse(s *capnp.Segment) (TlogResponse, error)

func ReadRootTlogResponse 

func ReadRootTlogResponse(msg *capnp.Message) (TlogResponse, error)

func (TlogResponse) HasSequences 

func (s TlogResponse) HasSequences() bool

func (TlogResponse) NewSequences 

func (s TlogResponse) NewSequences(n int32) (capnp.UInt64List, error)

NewSequences sets the sequences field to a newly allocated capnp.UInt64List, preferring placement in s's segment.

func (TlogResponse) Sequences 

func (s TlogResponse) Sequences() (capnp.UInt64List, error)

func (TlogResponse) SetSequences 

func (s TlogResponse) SetSequences(v capnp.UInt64List) error

func (TlogResponse) SetStatus 

func (s TlogResponse) SetStatus(v int8)

func (TlogResponse) Status 

func (s TlogResponse) Status() int8

func (TlogResponse) String 

func (s TlogResponse) String() string

type TlogResponse_List 

type TlogResponse_List struct{ capnp.List }

TlogResponse_List is a list of TlogResponse.

func NewTlogResponse_List 

func NewTlogResponse_List(s *capnp.Segment, sz int32) (TlogResponse_List, error)

NewTlogResponse creates a new list of TlogResponse.

func (TlogResponse_List) At 

func (s TlogResponse_List) At(i int) TlogResponse

func (TlogResponse_List) Set 

func (s TlogResponse_List) Set(i int, v TlogResponse) error

type TlogResponse_Promise 

type TlogResponse_Promise struct{ *capnp.Pipeline }

TlogResponse_Promise is a wrapper for a TlogResponse promised by a client call.

func (TlogResponse_Promise) Struct 

func (p TlogResponse_Promise) Struct() (TlogResponse, error)

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.