sinkpb

Documentation

Overview

Package sinkpb is a generated protocol buffer package.

It is generated from these files:

op.proto
snapshot.proto

It has these top-level messages:

Op
Cond
Instruction
Snapshot

Index

• Variables
• type Cond
  • func (*Cond) Descriptor() ([]byte, []int)
  • func (m *Cond) GetIndex() uint64
  • func (m *Cond) GetKey() string
  • func (m *Cond) GetType() Cond_Type
  • func (m *Cond) GetValue() []byte
  • func (*Cond) ProtoMessage()
  • func (m *Cond) Reset()
  • func (m *Cond) String() string
• type Cond_Type
  • func (Cond_Type) EnumDescriptor() ([]byte, []int)
  • func (x Cond_Type) String() string
• type Instruction
  • func (*Instruction) Descriptor() ([]byte, []int)
  • func (m *Instruction) GetConditions() []*Cond
  • func (m *Instruction) GetOperations() []*Op
  • func (*Instruction) ProtoMessage()
  • func (m *Instruction) Reset()
  • func (m *Instruction) String() string
• type Op
  • func (*Op) Descriptor() ([]byte, []int)
  • func (m *Op) GetKey() string
  • func (m *Op) GetType() Op_Type
  • func (m *Op) GetValue() []byte
  • func (*Op) ProtoMessage()
  • func (m *Op) Reset()
  • func (m *Op) String() string
• type Op_Type
  • func (Op_Type) EnumDescriptor() ([]byte, []int)
  • func (x Op_Type) String() string
• type Snapshot
  • func (*Snapshot) Descriptor() ([]byte, []int)
  • func (m *Snapshot) GetPeers() map[uint64]string
  • func (m *Snapshot) GetState() map[string][]byte
  • func (m *Snapshot) GetVersion() map[string]uint64
  • func (*Snapshot) ProtoMessage()
  • func (m *Snapshot) Reset()
  • func (m *Snapshot) String() string

Variables

var Cond_Type_name = map[int32]string{
	0: "KEY_EXISTS",
	1: "NOT_KEY_EXISTS",
	2: "VALUE_EQUAL",
	3: "NOT_VALUE_EQUAL",
	4: "INDEX_EQUAL",
	5: "NOT_INDEX_EQUAL",
}

var Cond_Type_value = map[string]int32{
	"KEY_EXISTS":      0,
	"NOT_KEY_EXISTS":  1,
	"VALUE_EQUAL":     2,
	"NOT_VALUE_EQUAL": 3,
	"INDEX_EQUAL":     4,
	"NOT_INDEX_EQUAL": 5,
}

var Op_Type_name = map[int32]string{
	0: "SET",
	1: "DELETE",
}

var Op_Type_value = map[string]int32{
	"SET":    0,
	"DELETE": 1,
}

Types

type Cond

type Cond struct {
	Type  Cond_Type `protobuf:"varint,1,opt,name=type,enum=sinkpb.Cond_Type" json:"type,omitempty"`
	Key   string    `protobuf:"bytes,2,opt,name=key" json:"key,omitempty"`
	Value []byte    `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	Index uint64    `protobuf:"varint,4,opt,name=index" json:"index,omitempty"`
}

func (*Cond) Descriptor

func (*Cond) Descriptor() ([]byte, []int)

func (*Cond) GetIndex

func (m *Cond) GetIndex() uint64

func (*Cond) GetKey

func (m *Cond) GetKey() string

func (*Cond) GetType

func (m *Cond) GetType() Cond_Type

func (*Cond) GetValue

func (m *Cond) GetValue() []byte

func (*Cond) ProtoMessage

func (*Cond) ProtoMessage()

func (*Cond) Reset

func (m *Cond) Reset()

func (*Cond) String

func (m *Cond) String() string

type Cond_Type

type Cond_Type int32

const (
	Cond_KEY_EXISTS      Cond_Type = 0
	Cond_NOT_KEY_EXISTS  Cond_Type = 1
	Cond_VALUE_EQUAL     Cond_Type = 2
	Cond_NOT_VALUE_EQUAL Cond_Type = 3
	Cond_INDEX_EQUAL     Cond_Type = 4
	Cond_NOT_INDEX_EQUAL Cond_Type = 5
)

func (Cond_Type) EnumDescriptor

func (Cond_Type) EnumDescriptor() ([]byte, []int)

func (Cond_Type) String

func (x Cond_Type) String() string

type Instruction

type Instruction struct {
	Conditions []*Cond `protobuf:"bytes,1,rep,name=conditions" json:"conditions,omitempty"`
	Operations []*Op   `protobuf:"bytes,2,rep,name=operations" json:"operations,omitempty"`
}

func (*Instruction) Descriptor

func (*Instruction) Descriptor() ([]byte, []int)

func (*Instruction) GetConditions

func (m *Instruction) GetConditions() []*Cond

func (*Instruction) GetOperations

func (m *Instruction) GetOperations() []*Op

func (*Instruction) ProtoMessage

func (*Instruction) ProtoMessage()

func (*Instruction) Reset

func (m *Instruction) Reset()

func (*Instruction) String

func (m *Instruction) String() string

type Op

type Op struct {
	Type  Op_Type `protobuf:"varint,1,opt,name=type,enum=sinkpb.Op_Type" json:"type,omitempty"`
	Key   string  `protobuf:"bytes,2,opt,name=key" json:"key,omitempty"`
	Value []byte  `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
}

func (*Op) Descriptor

func (*Op) Descriptor() ([]byte, []int)

func (*Op) GetKey

func (m *Op) GetKey() string

func (*Op) GetType

func (m *Op) GetType() Op_Type

func (*Op) GetValue

func (m *Op) GetValue() []byte

func (*Op) ProtoMessage

func (*Op) ProtoMessage()

func (*Op) Reset

func (m *Op) Reset()

func (*Op) String

func (m *Op) String() string

type Op_Type

type Op_Type int32

const (
	Op_SET    Op_Type = 0
	Op_DELETE Op_Type = 1
)

func (Op_Type) EnumDescriptor

func (Op_Type) EnumDescriptor() ([]byte, []int)

func (Op_Type) String

func (x Op_Type) String() string

type Snapshot

type Snapshot struct {
	Version map[string]uint64 `` /* 135-byte string literal not displayed */
	State   map[string][]byte `` /* 137-byte string literal not displayed */
	Peers   map[uint64]string `` /* 131-byte string literal not displayed */
}

func (*Snapshot) Descriptor

func (*Snapshot) Descriptor() ([]byte, []int)

func (*Snapshot) GetPeers

func (m *Snapshot) GetPeers() map[uint64]string

func (*Snapshot) GetState

func (m *Snapshot) GetState() map[string][]byte

func (*Snapshot) GetVersion

func (m *Snapshot) GetVersion() map[string]uint64

func (*Snapshot) ProtoMessage

func (*Snapshot) ProtoMessage()

func (*Snapshot) Reset

func (m *Snapshot) Reset()

func (*Snapshot) String

func (m *Snapshot) String() string