types

package
v0.0.0-...-fbf4a61 Latest Latest
Warning

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

 Go to latest Published: Jun 12, 2020 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthTypes        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTypes          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTypes = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var Change_ChangeType_name = map[int32]string{
	0: "NONE",
	1: "JOIN",
	2: "REMOVE",
}
View Source 
var Change_ChangeType_value = map[string]int32{
	"NONE":   0,
	"JOIN":   1,
	"REMOVE": 2,
}

Functions

func EqualValues 

func EqualValues(a, b *Value) bool

func IsBroadcast 

func IsBroadcast(msg *Message) bool

Types

type Accept 

type Accept struct {
	Ballot   uint64 `protobuf:"varint,1,opt,name=ballot,proto3" json:"ballot,omitempty"`
	Sequence uint64 `protobuf:"varint,2,opt,name=sequence,proto3" json:"sequence,omitempty"`
	Value    *Value `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
}

func (*Accept) Descriptor 

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

func (*Accept) GetBallot 

func (m *Accept) GetBallot() uint64

func (*Accept) GetSequence 

func (m *Accept) GetSequence() uint64

func (*Accept) GetValue 

func (m *Accept) GetValue() *Value

func (*Accept) Marshal 

func (m *Accept) Marshal() (dAtA []byte, err error)

func (*Accept) MarshalTo 

func (m *Accept) MarshalTo(dAtA []byte) (int, error)

func (*Accept) MarshalToSizedBuffer 

func (m *Accept) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Accept) ProtoMessage 

func (*Accept) ProtoMessage()

func (*Accept) Reset 

func (m *Accept) Reset()

func (*Accept) Size 

func (m *Accept) Size() (n int)

func (*Accept) String 

func (m *Accept) String() string

func (*Accept) Unmarshal 

func (m *Accept) Unmarshal(dAtA []byte) error

func (*Accept) XXX_DiscardUnknown 

func (m *Accept) XXX_DiscardUnknown()

func (*Accept) XXX_Marshal 

func (m *Accept) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Accept) XXX_Merge 

func (m *Accept) XXX_Merge(src proto.Message)

func (*Accept) XXX_Size 

func (m *Accept) XXX_Size() int

func (*Accept) XXX_Unmarshal 

func (m *Accept) XXX_Unmarshal(b []byte) error

type Accepted 

type Accepted struct {
	Ballot   uint64 `protobuf:"varint,1,opt,name=ballot,proto3" json:"ballot,omitempty"`
	Sequence uint64 `protobuf:"varint,2,opt,name=sequence,proto3" json:"sequence,omitempty"`
	Value    *Value `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
}

func (*Accepted) Descriptor 

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

func (*Accepted) GetBallot 

func (m *Accepted) GetBallot() uint64

func (*Accepted) GetSequence 

func (m *Accepted) GetSequence() uint64

func (*Accepted) GetValue 

func (m *Accepted) GetValue() *Value

func (*Accepted) Marshal 

func (m *Accepted) Marshal() (dAtA []byte, err error)

func (*Accepted) MarshalTo 

func (m *Accepted) MarshalTo(dAtA []byte) (int, error)

func (*Accepted) MarshalToSizedBuffer 

func (m *Accepted) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Accepted) ProtoMessage 

func (*Accepted) ProtoMessage()

func (*Accepted) Reset 

func (m *Accepted) Reset()

func (*Accepted) Size 

func (m *Accepted) Size() (n int)

func (*Accepted) String 

func (m *Accepted) String() string

func (*Accepted) Unmarshal 

func (m *Accepted) Unmarshal(dAtA []byte) error

func (*Accepted) XXX_DiscardUnknown 

func (m *Accepted) XXX_DiscardUnknown()

func (*Accepted) XXX_Marshal 

func (m *Accepted) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Accepted) XXX_Merge 

func (m *Accepted) XXX_Merge(src proto.Message)

func (*Accepted) XXX_Size 

func (m *Accepted) XXX_Size() int

func (*Accepted) XXX_Unmarshal 

func (m *Accepted) XXX_Unmarshal(b []byte) error

type Alert 

type Alert struct {
	Observer uint64  `protobuf:"varint,1,opt,name=observer,proto3" json:"observer,omitempty"`
	Subject  uint64  `protobuf:"varint,2,opt,name=subject,proto3" json:"subject,omitempty"`
	Change   *Change `protobuf:"bytes,3,opt,name=change,proto3" json:"change,omitempty"`
}

func (*Alert) Descriptor 

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

func (*Alert) GetChange 

func (m *Alert) GetChange() *Change

func (*Alert) GetObserver 

func (m *Alert) GetObserver() uint64

func (*Alert) GetSubject 

func (m *Alert) GetSubject() uint64

func (*Alert) Marshal 

func (m *Alert) Marshal() (dAtA []byte, err error)

func (*Alert) MarshalTo 

func (m *Alert) MarshalTo(dAtA []byte) (int, error)

func (*Alert) MarshalToSizedBuffer 

func (m *Alert) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Alert) ProtoMessage 

func (*Alert) ProtoMessage()

func (*Alert) Reset 

func (m *Alert) Reset()

func (*Alert) Size 

func (m *Alert) Size() (n int)

func (*Alert) String 

func (m *Alert) String() string

func (*Alert) Unmarshal 

func (m *Alert) Unmarshal(dAtA []byte) error

func (*Alert) XXX_DiscardUnknown 

func (m *Alert) XXX_DiscardUnknown()

func (*Alert) XXX_Marshal 

func (m *Alert) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Alert) XXX_Merge 

func (m *Alert) XXX_Merge(src proto.Message)

func (*Alert) XXX_Size 

func (m *Alert) XXX_Size() int

func (*Alert) XXX_Unmarshal 

func (m *Alert) XXX_Unmarshal(b []byte) error

type Change 

type Change struct {
	Type Change_ChangeType `protobuf:"varint,1,opt,name=type,proto3,enum=types.Change_ChangeType" json:"type,omitempty"`
	Node *Node             `protobuf:"bytes,2,opt,name=node,proto3" json:"node,omitempty"`
}

func (*Change) Descriptor 

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

func (*Change) GetNode 

func (m *Change) GetNode() *Node

func (*Change) GetType 

func (m *Change) GetType() Change_ChangeType

func (*Change) Marshal 

func (m *Change) Marshal() (dAtA []byte, err error)

func (*Change) MarshalTo 

func (m *Change) MarshalTo(dAtA []byte) (int, error)

func (*Change) MarshalToSizedBuffer 

func (m *Change) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Change) ProtoMessage 

func (*Change) ProtoMessage()

func (*Change) Reset 

func (m *Change) Reset()

func (*Change) Size 

func (m *Change) Size() (n int)

func (*Change) String 

func (m *Change) String() string

func (*Change) Unmarshal 

func (m *Change) Unmarshal(dAtA []byte) error

func (*Change) XXX_DiscardUnknown 

func (m *Change) XXX_DiscardUnknown()

func (*Change) XXX_Marshal 

func (m *Change) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Change) XXX_Merge 

func (m *Change) XXX_Merge(src proto.Message)

func (*Change) XXX_Size 

func (m *Change) XXX_Size() int

func (*Change) XXX_Unmarshal 

func (m *Change) XXX_Unmarshal(b []byte) error

type Change_ChangeType 

type Change_ChangeType int32
const (
	Change_NONE   Change_ChangeType = 0
	Change_JOIN   Change_ChangeType = 1
	Change_REMOVE Change_ChangeType = 2
)

func (Change_ChangeType) EnumDescriptor 

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

func (Change_ChangeType) String 

func (x Change_ChangeType) String() string

type Configuration 

type Configuration struct {
	ID    uint64  `protobuf:"varint,1,opt,name=ID,json=iD,proto3" json:"ID,omitempty"`
	Nodes []*Node `protobuf:"bytes,2,rep,name=nodes,proto3" json:"nodes,omitempty"`
}

func (*Configuration) Descriptor 

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

func (*Configuration) GetID 

func (m *Configuration) GetID() uint64

func (*Configuration) GetNodes 

func (m *Configuration) GetNodes() []*Node

func (*Configuration) Marshal 

func (m *Configuration) Marshal() (dAtA []byte, err error)

func (*Configuration) MarshalTo 

func (m *Configuration) MarshalTo(dAtA []byte) (int, error)

func (*Configuration) MarshalToSizedBuffer 

func (m *Configuration) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Configuration) ProtoMessage 

func (*Configuration) ProtoMessage()

func (*Configuration) Reset 

func (m *Configuration) Reset()

func (*Configuration) Size 

func (m *Configuration) Size() (n int)

func (*Configuration) String 

func (m *Configuration) String() string

func (*Configuration) Unmarshal 

func (m *Configuration) Unmarshal(dAtA []byte) error

func (*Configuration) XXX_DiscardUnknown 

func (m *Configuration) XXX_DiscardUnknown()

func (*Configuration) XXX_Marshal 

func (m *Configuration) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Configuration) XXX_Merge 

func (m *Configuration) XXX_Merge(src proto.Message)

func (*Configuration) XXX_Size 

func (m *Configuration) XXX_Size() int

func (*Configuration) XXX_Unmarshal 

func (m *Configuration) XXX_Unmarshal(b []byte) error

type LastConfiguration 

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

LastConfiguration is a utility to broadcast updates. When channel notification is received

func Last 

func Last(conf *Configuration) *LastConfiguration

func (*LastConfiguration) Configuration 

func (c *LastConfiguration) Configuration() *Configuration

func (*LastConfiguration) Last 

func (c *LastConfiguration) Last() (*Configuration, <-chan struct{})

func (*LastConfiguration) Update 

func (c *LastConfiguration) Update(conf *Configuration)

type LearnedValue 

type LearnedValue struct {
	Ballot   uint64 `protobuf:"varint,1,opt,name=ballot,proto3" json:"ballot,omitempty"`
	Sequence uint64 `protobuf:"varint,2,opt,name=sequence,proto3" json:"sequence,omitempty"`
	Value    *Value `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
}

func (*LearnedValue) Descriptor 

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

func (*LearnedValue) GetBallot 

func (m *LearnedValue) GetBallot() uint64

func (*LearnedValue) GetSequence 

func (m *LearnedValue) GetSequence() uint64

func (*LearnedValue) GetValue 

func (m *LearnedValue) GetValue() *Value

func (*LearnedValue) Marshal 

func (m *LearnedValue) Marshal() (dAtA []byte, err error)

func (*LearnedValue) MarshalTo 

func (m *LearnedValue) MarshalTo(dAtA []byte) (int, error)

func (*LearnedValue) MarshalToSizedBuffer 

func (m *LearnedValue) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LearnedValue) ProtoMessage 

func (*LearnedValue) ProtoMessage()

func (*LearnedValue) Reset 

func (m *LearnedValue) Reset()

func (*LearnedValue) Size 

func (m *LearnedValue) Size() (n int)

func (*LearnedValue) String 

func (m *LearnedValue) String() string

func (*LearnedValue) Unmarshal 

func (m *LearnedValue) Unmarshal(dAtA []byte) error

func (*LearnedValue) XXX_DiscardUnknown 

func (m *LearnedValue) XXX_DiscardUnknown()

func (*LearnedValue) XXX_Marshal 

func (m *LearnedValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LearnedValue) XXX_Merge 

func (m *LearnedValue) XXX_Merge(src proto.Message)

func (*LearnedValue) XXX_Size 

func (m *LearnedValue) XXX_Size() int

func (*LearnedValue) XXX_Unmarshal 

func (m *LearnedValue) XXX_Unmarshal(b []byte) error

type Message 

type Message struct {
	SeqNum     uint64   `protobuf:"varint,1,opt,name=seqNum,proto3" json:"seqNum,omitempty"`
	From       uint64   `protobuf:"varint,2,opt,name=from,proto3" json:"from,omitempty"`
	To         []uint64 `protobuf:"varint,3,rep,packed,name=to,proto3" json:"to,omitempty"`
	InstanceID uint64   `protobuf:"varint,4,opt,name=instanceID,proto3" json:"instanceID,omitempty"`
	// Types that are valid to be assigned to Type:
	//	*Message_Prepare
	//	*Message_Promise
	//	*Message_Accept
	//	*Message_Accepted
	//	*Message_Alert
	Type isMessage_Type `protobuf_oneof:"type"`
}

func NewAcceptMessage 

func NewAcceptMessage(ballot, seq uint64, value *Value) *Message

func NewAcceptedMessage 

func NewAcceptedMessage(ballot, seq uint64, value *Value) *Message

func NewAlert 

func NewAlert(observer, subject uint64, change *Change) *Message

func NewPrepareMessage 

func NewPrepareMessage(ballot, seq uint64) *Message

func NewPromiseMessage 

func NewPromiseMessage(ballot, seq, voteBallot uint64, value *Value) *Message

func WithInstance 

func WithInstance(instance uint64, msg *Message) *Message

func WithRouting 

func WithRouting(from uint64, to []uint64, msg *Message) *Message

WithRouting mutates original msg objects, by adding passed from, to fields to the object.

func (*Message) Descriptor 

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

func (*Message) GetAccept 

func (m *Message) GetAccept() *Accept

func (*Message) GetAccepted 

func (m *Message) GetAccepted() *Accepted

func (*Message) GetAlert 

func (m *Message) GetAlert() *Alert

func (*Message) GetFrom 

func (m *Message) GetFrom() uint64

func (*Message) GetInstanceID 

func (m *Message) GetInstanceID() uint64

func (*Message) GetPrepare 

func (m *Message) GetPrepare() *Prepare

func (*Message) GetPromise 

func (m *Message) GetPromise() *Promise

func (*Message) GetSeqNum 

func (m *Message) GetSeqNum() uint64

func (*Message) GetTo 

func (m *Message) GetTo() []uint64

func (*Message) GetType 

func (m *Message) GetType() isMessage_Type

func (*Message) Marshal 

func (m *Message) Marshal() (dAtA []byte, err error)

func (*Message) MarshalTo 

func (m *Message) MarshalTo(dAtA []byte) (int, error)

func (*Message) MarshalToSizedBuffer 

func (m *Message) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) Reset 

func (m *Message) Reset()

func (*Message) Size 

func (m *Message) Size() (n int)

func (*Message) String 

func (m *Message) String() string

func (*Message) Unmarshal 

func (m *Message) Unmarshal(dAtA []byte) error

func (*Message) XXX_DiscardUnknown 

func (m *Message) XXX_DiscardUnknown()

func (*Message) XXX_Marshal 

func (m *Message) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Message) XXX_Merge 

func (m *Message) XXX_Merge(src proto.Message)

func (*Message) XXX_OneofWrappers 

func (*Message) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Message) XXX_Size 

func (m *Message) XXX_Size() int

func (*Message) XXX_Unmarshal 

func (m *Message) XXX_Unmarshal(b []byte) error

type Message_Accept 

type Message_Accept struct {
	Accept *Accept `protobuf:"bytes,7,opt,name=accept,proto3,oneof" json:"accept,omitempty"`
}

func (*Message_Accept) MarshalTo 

func (m *Message_Accept) MarshalTo(dAtA []byte) (int, error)

func (*Message_Accept) MarshalToSizedBuffer 

func (m *Message_Accept) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Message_Accept) Size 

func (m *Message_Accept) Size() (n int)

type Message_Accepted 

type Message_Accepted struct {
	Accepted *Accepted `protobuf:"bytes,8,opt,name=accepted,proto3,oneof" json:"accepted,omitempty"`
}

func (*Message_Accepted) MarshalTo 

func (m *Message_Accepted) MarshalTo(dAtA []byte) (int, error)

func (*Message_Accepted) MarshalToSizedBuffer 

func (m *Message_Accepted) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Message_Accepted) Size 

func (m *Message_Accepted) Size() (n int)

type Message_Alert 

type Message_Alert struct {
	Alert *Alert `protobuf:"bytes,9,opt,name=alert,proto3,oneof" json:"alert,omitempty"`
}

func (*Message_Alert) MarshalTo 

func (m *Message_Alert) MarshalTo(dAtA []byte) (int, error)

func (*Message_Alert) MarshalToSizedBuffer 

func (m *Message_Alert) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Message_Alert) Size 

func (m *Message_Alert) Size() (n int)

type Message_Prepare 

type Message_Prepare struct {
	Prepare *Prepare `protobuf:"bytes,5,opt,name=prepare,proto3,oneof" json:"prepare,omitempty"`
}

func (*Message_Prepare) MarshalTo 

func (m *Message_Prepare) MarshalTo(dAtA []byte) (int, error)

func (*Message_Prepare) MarshalToSizedBuffer 

func (m *Message_Prepare) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Message_Prepare) Size 

func (m *Message_Prepare) Size() (n int)

type Message_Promise 

type Message_Promise struct {
	Promise *Promise `protobuf:"bytes,6,opt,name=promise,proto3,oneof" json:"promise,omitempty"`
}

func (*Message_Promise) MarshalTo 

func (m *Message_Promise) MarshalTo(dAtA []byte) (int, error)

func (*Message_Promise) MarshalToSizedBuffer 

func (m *Message_Promise) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Message_Promise) Size 

func (m *Message_Promise) Size() (n int)

type Node 

type Node struct {
	ID     uint64            `protobuf:"varint,1,opt,name=ID,json=iD,proto3" json:"ID,omitempty"`
	IP     string            `protobuf:"bytes,2,opt,name=IP,json=iP,proto3" json:"IP,omitempty"`
	Port   uint64            `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`
	Config map[string]string `` /* 153-byte string literal not displayed */
}

func (*Node) Descriptor 

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

func (*Node) GetConfig 

func (m *Node) GetConfig() map[string]string

func (*Node) GetID 

func (m *Node) GetID() uint64

func (*Node) GetIP 

func (m *Node) GetIP() string

func (*Node) GetPort 

func (m *Node) GetPort() uint64

func (*Node) Marshal 

func (m *Node) Marshal() (dAtA []byte, err error)

func (*Node) MarshalTo 

func (m *Node) MarshalTo(dAtA []byte) (int, error)

func (*Node) MarshalToSizedBuffer 

func (m *Node) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) Reset 

func (m *Node) Reset()

func (*Node) Size 

func (m *Node) Size() (n int)

func (*Node) String 

func (m *Node) String() string

func (*Node) Unmarshal 

func (m *Node) Unmarshal(dAtA []byte) error

func (*Node) XXX_DiscardUnknown 

func (m *Node) XXX_DiscardUnknown()

func (*Node) XXX_Marshal 

func (m *Node) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Node) XXX_Merge 

func (m *Node) XXX_Merge(src proto.Message)

func (*Node) XXX_Size 

func (m *Node) XXX_Size() int

func (*Node) XXX_Unmarshal 

func (m *Node) XXX_Unmarshal(b []byte) error

type Prepare 

type Prepare struct {
	Ballot   uint64 `protobuf:"varint,1,opt,name=ballot,proto3" json:"ballot,omitempty"`
	Sequence uint64 `protobuf:"varint,2,opt,name=sequence,proto3" json:"sequence,omitempty"`
}

func (*Prepare) Descriptor 

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

func (*Prepare) GetBallot 

func (m *Prepare) GetBallot() uint64

func (*Prepare) GetSequence 

func (m *Prepare) GetSequence() uint64

func (*Prepare) Marshal 

func (m *Prepare) Marshal() (dAtA []byte, err error)

func (*Prepare) MarshalTo 

func (m *Prepare) MarshalTo(dAtA []byte) (int, error)

func (*Prepare) MarshalToSizedBuffer 

func (m *Prepare) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Prepare) ProtoMessage 

func (*Prepare) ProtoMessage()

func (*Prepare) Reset 

func (m *Prepare) Reset()

func (*Prepare) Size 

func (m *Prepare) Size() (n int)

func (*Prepare) String 

func (m *Prepare) String() string

func (*Prepare) Unmarshal 

func (m *Prepare) Unmarshal(dAtA []byte) error

func (*Prepare) XXX_DiscardUnknown 

func (m *Prepare) XXX_DiscardUnknown()

func (*Prepare) XXX_Marshal 

func (m *Prepare) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Prepare) XXX_Merge 

func (m *Prepare) XXX_Merge(src proto.Message)

func (*Prepare) XXX_Size 

func (m *Prepare) XXX_Size() int

func (*Prepare) XXX_Unmarshal 

func (m *Prepare) XXX_Unmarshal(b []byte) error

type Promise 

type Promise struct {
	Ballot           uint64 `protobuf:"varint,1,opt,name=ballot,proto3" json:"ballot,omitempty"`
	Sequence         uint64 `protobuf:"varint,2,opt,name=sequence,proto3" json:"sequence,omitempty"`
	VoteBallot       uint64 `protobuf:"varint,3,opt,name=voteBallot,proto3" json:"voteBallot,omitempty"`
	Value            *Value `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	CommitedSequence uint64 `protobuf:"varint,5,opt,name=commitedSequence,proto3" json:"commitedSequence,omitempty"`
}

func (*Promise) Descriptor 

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

func (*Promise) GetBallot 

func (m *Promise) GetBallot() uint64

func (*Promise) GetCommitedSequence 

func (m *Promise) GetCommitedSequence() uint64

func (*Promise) GetSequence 

func (m *Promise) GetSequence() uint64

func (*Promise) GetValue 

func (m *Promise) GetValue() *Value

func (*Promise) GetVoteBallot 

func (m *Promise) GetVoteBallot() uint64

func (*Promise) Marshal 

func (m *Promise) Marshal() (dAtA []byte, err error)

func (*Promise) MarshalTo 

func (m *Promise) MarshalTo(dAtA []byte) (int, error)

func (*Promise) MarshalToSizedBuffer 

func (m *Promise) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Promise) ProtoMessage 

func (*Promise) ProtoMessage()

func (*Promise) Reset 

func (m *Promise) Reset()

func (*Promise) Size 

func (m *Promise) Size() (n int)

func (*Promise) String 

func (m *Promise) String() string

func (*Promise) Unmarshal 

func (m *Promise) Unmarshal(dAtA []byte) error

func (*Promise) XXX_DiscardUnknown 

func (m *Promise) XXX_DiscardUnknown()

func (*Promise) XXX_Marshal 

func (m *Promise) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Promise) XXX_Merge 

func (m *Promise) XXX_Merge(src proto.Message)

func (*Promise) XXX_Size 

func (m *Promise) XXX_Size() int

func (*Promise) XXX_Unmarshal 

func (m *Promise) XXX_Unmarshal(b []byte) error

type Value 

type Value struct {
	Changes []*Change `protobuf:"bytes,1,rep,name=changes,proto3" json:"changes,omitempty"`
}

func (*Value) Descriptor 

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

func (*Value) GetChanges 

func (m *Value) GetChanges() []*Change

func (*Value) Marshal 

func (m *Value) Marshal() (dAtA []byte, err error)

func (*Value) MarshalTo 

func (m *Value) MarshalTo(dAtA []byte) (int, error)

func (*Value) MarshalToSizedBuffer 

func (m *Value) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Value) ProtoMessage 

func (*Value) ProtoMessage()

func (*Value) Reset 

func (m *Value) Reset()

func (*Value) Size 

func (m *Value) Size() (n int)

func (*Value) String 

func (m *Value) String() string

func (*Value) Unmarshal 

func (m *Value) Unmarshal(dAtA []byte) error

func (*Value) XXX_DiscardUnknown 

func (m *Value) XXX_DiscardUnknown()

func (*Value) XXX_Marshal 

func (m *Value) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Value) XXX_Merge 

func (m *Value) XXX_Merge(src proto.Message)

func (*Value) XXX_Size 

func (m *Value) XXX_Size() int

func (*Value) XXX_Unmarshal 

func (m *Value) XXX_Unmarshal(b []byte) 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.