proto

package

Go to main page

Versions in this module

v0

v0.2.1

Mar 10, 2023

v0.2.0

Mar 2, 2023

Changes in this version

+ var CommandCreate = "CREATE"

+ type CreateTopicRequest struct

+ Schema string

+ Topic string

+ func (rq *CreateTopicRequest) Unmarshal(b []byte) error

+ func (rq CreateTopicRequest) Marshal() ([]byte, error)

type ErrResponse

+ func (v ErrResponse) Headers() []string

+ func (v ErrResponse) Values() [][]string

type ListRequest

+ Object string

type ListResponse

+ ObjectList []string

+ func (v ListResponse) Headers() []string

+ func (v ListResponse) Values() [][]string

type OkResponse

+ func (v OkResponse) Headers() []string

+ func (v OkResponse) Values() [][]string

+ type Printable interface

+ Headers func() []string

+ Values func() [][]string

type QueryResponse

+ func (v QueryResponse) Headers() []string

+ func (v QueryResponse) Values() [][]string

type StatsResponse

+ Topics int

+ func (v StatsResponse) Headers() []string

+ func (v StatsResponse) Values() [][]string

type VersionResponse

+ func (v VersionResponse) Headers() []string

+ func (v VersionResponse) Values() [][]string

v0.1.5

Jan 9, 2023

v0.1.4

Dec 29, 2022

v0.1.3

Dec 20, 2022

v0.1.2

Dec 18, 2022

v0.1.1

Dec 17, 2022

v0.1.0

Dec 8, 2022

Changes in this version

+ var CommandAppend = "APPEND"

+ var CommandError = "ERR"

+ var CommandList = "LIST"

+ var CommandOk = "OK"

+ var CommandQuery = "QUERY"

+ var CommandStats = "STATS"

+ var CommandUse = "USE"

+ var CommandVersion = "VERSION"

+ var MessageError = NewMessageWithType(CommandError, ErrResponse{ ... })

+ var MessageErrorCommandNotFound = NewMessageWithType(CommandError, ErrResponse{ ... })

+ var MessageErrorMalformedMessage = NewMessageWithType(CommandError, ErrResponse{ ... })

+ var MessageErrorUnknownDb = NewMessageWithType(CommandList, ListRequest{})

+ var MessageErrorUnmarshaling = NewMessageWithType(CommandError, ErrResponse{ ... })

+ var MessageList = NewMessageWithType(CommandError, ErrResponse{ ... })

+ var MessageOk = NewMessageWithType(CommandOk, OkResponse{ ... })

+ var MessageOkDatabaseChanged = NewMessageWithType(CommandOk, OkResponse{ ... })

+ var Protocol = "fossil"

+ var Version = "v1.0.0"

+ func Marshal(t Marshaler) ([]byte, error)

+ func Unmarshal(b []byte, t Unmarshaler) error

+ type AppendRequest struct

+ Data []byte

+ Topic string

+ func (rq *AppendRequest) Unmarshal(b []byte) error

+ func (rq AppendRequest) Marshal() ([]byte, error)

+ type ConnectionString struct

+ Address string

+ Database string

+ Local bool

+ func ParseConnectionString(connStr string) ConnectionString

+ type ErrResponse struct

+ Code uint32

+ Err error

+ func (rq *ErrResponse) Unmarshal(b []byte) error

+ func (rq ErrResponse) Marshal() ([]byte, error)

+ type ListRequest struct

+ func (rq *ListRequest) Unmarshal(b []byte) error

+ func (rq ListRequest) Marshal() ([]byte, error)

+ type ListResponse struct

+ DatabaseList []string

+ func (rq *ListResponse) Unmarshal(b []byte) error

+ func (rq ListResponse) Marshal() ([]byte, error)

+ type Marshaler interface

+ Marshal func() ([]byte, error)

+ type Message struct

+ Command string

+ Data []byte

+ func NewMessage(cmd string, data []byte) Message

+ func NewMessageWithType(cmd string, t Marshaler) Message

+ func ReadMessageFull(r io.Reader) (Message, error)

+ func (m *Message) Unmarshal(r io.Reader) error

+ func (m Message) Marshal() ([]byte, error)

+ func (m Message) MarshalZerologObject(e *zerolog.Event)

+ type OkResponse struct

+ Code uint32

+ Message string

+ func (rq *OkResponse) Unmarshal(b []byte) error

+ func (rq OkResponse) Marshal() ([]byte, error)

+ type QueryRequest struct

+ Query string

+ func (rq *QueryRequest) Unmarshal(b []byte) error

+ func (rq QueryRequest) Marshal() ([]byte, error)

+ type QueryResponse struct

+ Results database.Entries

+ func (rq *QueryResponse) Unmarshal(b []byte) error

+ func (rq QueryResponse) Marshal() ([]byte, error)

+ type Request struct

+ func NewRequest(msg Message, db *database.Database) *Request

+ func (r *Request) Command() string

+ func (r *Request) Data() []byte

+ func (r *Request) Database() *database.Database

+ type ResponseWriter struct

+ func NewResponseWriter(w io.Writer) ResponseWriter

+ func (rw ResponseWriter) Write(b []byte) (int, error)

+ func (rw ResponseWriter) WriteMessage(t Marshaler) (int, error)

+ type StatsRequest struct

+ Database string

+ func (rq *StatsRequest) Unmarshal(b []byte) error

+ func (rq StatsRequest) Marshal() ([]byte, error)

+ type StatsResponse struct

+ AllocHeap uint64

+ Segments int

+ TotalMem uint64

+ Uptime time.Duration

+ func (rq *StatsResponse) Unmarshal(b []byte) error

+ func (rq StatsResponse) Marshal() ([]byte, error)

+ type Unmarshaler interface

+ Unmarshal func([]byte) error

+ type UseRequest struct

+ DbName string

+ func (rq *UseRequest) Unmarshal(b []byte) error

+ func (rq UseRequest) Marshal() ([]byte, error)

+ type VersionRequest struct

+ Version string

+ func (v *VersionRequest) Unmarshal(b []byte) error

+ func (v VersionRequest) Marshal() ([]byte, error)

+ type VersionResponse struct

+ Code uint32

+ Version string

+ func (v *VersionResponse) Unmarshal(b []byte) error

+ func (v VersionResponse) Marshal() ([]byte, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL