message

Documentation

Overview

Package message is a generated protocol buffer package.

It is generated from these files:

github.com/GoCollaborate/src/artifacts/message/message.proto

It has these top-level messages:

CardMessage
Status

Index

• Variables
• type Card
  • func (m *Card) GetAPI() string
  • func (m *Card) GetAlive() bool
  • func (m *Card) GetIP() string
  • func (m *Card) GetPort() int32
  • func (m *Card) GetSeed() bool
  • func (*Card) ProtoMessage()
  • func (m *Card) Reset()
  • func (m *Card) String() string
• type CardMessage
  • func NewCardMessage() *CardMessage
  • func NewCardMessageWithOptions(cluster string, from *card.Card, to *card.Card, cards map[string]*card.Card, ...) *CardMessage
  • func (cm *CardMessage) DeleteDigestCard(key string)
  • func (*CardMessage) Descriptor() ([]byte, []int)
  • func (m *CardMessage) GetCluster() string
  • func (m *CardMessage) GetDigest() *digest.Digest
  • func (m *CardMessage) GetFrom() *card.Card
  • func (m *CardMessage) GetStatus() *Status
  • func (m *CardMessage) GetTo() *card.Card
  • func (m *CardMessage) GetType() CardMessage_Type
  • func (*CardMessage) ProtoMessage()
  • func (m *CardMessage) Reset()
  • func (cm *CardMessage) SetCards(cards map[string]*card.Card) *CardMessage
  • func (cm *CardMessage) SetCluster(cluster string) *CardMessage
  • func (cm *CardMessage) SetFrom(from *card.Card) *CardMessage
  • func (cm *CardMessage) SetStatus(status constants.Header) *CardMessage
  • func (cm *CardMessage) SetTimeStamp(timestamp int64) *CardMessage
  • func (cm *CardMessage) SetTo(to *card.Card) *CardMessage
  • func (cm *CardMessage) SetType(msgType CardMessage_Type) *CardMessage
  • func (cm *CardMessage) Stamp()
  • func (m *CardMessage) String() string
  • func (cm *CardMessage) Update(dgst iremote.IDigest)
• type CardMessageFuture
  • func NewCardMessageFuture(in *CardMessage) *CardMessageFuture
  • func (cf *CardMessageFuture) Close()
  • func (cf *CardMessageFuture) Done() *CardMessage
  • func (cf *CardMessageFuture) Error() error
  • func (cf *CardMessageFuture) Receive() *CardMessage
  • func (cf *CardMessageFuture) Return(out *CardMessage)
• type CardMessage_Type
  • func (CardMessage_Type) EnumDescriptor() ([]byte, []int)
  • func (x CardMessage_Type) String() string
• type Digest
  • func (m *Digest) GetCards() map[string]*Card
  • func (m *Digest) GetTs() int64
  • func (*Digest) ProtoMessage()
  • func (m *Digest) Reset()
  • func (m *Digest) String() string
• type Status
  • func (*Status) Descriptor() ([]byte, []int)
  • func (m *Status) GetKey() string
  • func (m *Status) GetValue() string
  • func (*Status) ProtoMessage()
  • func (m *Status) Reset()
  • func (m *Status) String() string

Variables

var CardMessage_Type_name = map[int32]string{
	0: "ACK",
	1: "ACK2",
	2: "ACK3",
	3: "SYNC",
}

var CardMessage_Type_value = map[string]int32{
	"ACK":  0,
	"ACK2": 1,
	"ACK3": 2,
	"SYNC": 3,
}

Types

type Card

type Card card.Card

Card from public import github.com/GoCollaborate/src/artifacts/card/card.proto

func (*Card) GetAPI

func (m *Card) GetAPI() string

func (*Card) GetAlive

func (m *Card) GetAlive() bool

func (*Card) GetIP

func (m *Card) GetIP() string

func (*Card) GetPort

func (m *Card) GetPort() int32

func (*Card) GetSeed

func (m *Card) GetSeed() bool

func (*Card) ProtoMessage

func (*Card) ProtoMessage()

func (*Card) Reset

func (m *Card) Reset()

func (*Card) String

func (m *Card) String() string

type CardMessage

type CardMessage struct {
	Cluster string           `protobuf:"bytes,1,opt,name=cluster" json:"cluster,omitempty"`
	From    *card.Card       `protobuf:"bytes,2,opt,name=from" json:"from,omitempty"`
	To      *card.Card       `protobuf:"bytes,3,opt,name=to" json:"to,omitempty"`
	Status  *Status          `protobuf:"bytes,4,opt,name=status" json:"status,omitempty"`
	Type    CardMessage_Type `protobuf:"varint,5,opt,name=type,enum=message.CardMessage_Type" json:"type,omitempty"`
	Digest  *digest.Digest   `protobuf:"bytes,6,opt,name=digest" json:"digest,omitempty"`
}

func NewCardMessage

func NewCardMessage() *CardMessage

func NewCardMessageWithOptions

func NewCardMessageWithOptions(cluster string, from *card.Card, to *card.Card, cards map[string]*card.Card, timestamp int64, msgType CardMessage_Type) *CardMessage

func (*CardMessage) DeleteDigestCard

func (cm *CardMessage) DeleteDigestCard(key string)

func (*CardMessage) Descriptor

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

func (*CardMessage) GetCluster

func (m *CardMessage) GetCluster() string

func (*CardMessage) GetDigest

func (m *CardMessage) GetDigest() *digest.Digest

func (*CardMessage) GetFrom

func (m *CardMessage) GetFrom() *card.Card

func (*CardMessage) GetStatus

func (m *CardMessage) GetStatus() *Status

func (*CardMessage) GetTo

func (m *CardMessage) GetTo() *card.Card

func (*CardMessage) GetType

func (m *CardMessage) GetType() CardMessage_Type

func (*CardMessage) ProtoMessage

func (*CardMessage) ProtoMessage()

func (*CardMessage) Reset

func (m *CardMessage) Reset()

func (*CardMessage) SetCards

func (cm *CardMessage) SetCards(cards map[string]*card.Card) *CardMessage

func (*CardMessage) SetCluster

func (cm *CardMessage) SetCluster(cluster string) *CardMessage

func (*CardMessage) SetFrom

func (cm *CardMessage) SetFrom(from *card.Card) *CardMessage

func (*CardMessage) SetStatus

func (cm *CardMessage) SetStatus(status constants.Header) *CardMessage

func (*CardMessage) SetTimeStamp

func (cm *CardMessage) SetTimeStamp(timestamp int64) *CardMessage

func (*CardMessage) SetTo

func (cm *CardMessage) SetTo(to *card.Card) *CardMessage

func (*CardMessage) SetType

func (cm *CardMessage) SetType(msgType CardMessage_Type) *CardMessage

func (*CardMessage) Stamp

func (cm *CardMessage) Stamp()

func (*CardMessage) String

func (m *CardMessage) String() string

func (*CardMessage) Update

func (cm *CardMessage) Update(dgst iremote.IDigest)

type CardMessageFuture

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

func NewCardMessageFuture

func NewCardMessageFuture(in *CardMessage) *CardMessageFuture

func (*CardMessageFuture) Close

func (cf *CardMessageFuture) Close()

func (*CardMessageFuture) Done

func (cf *CardMessageFuture) Done() *CardMessage

func (*CardMessageFuture) Error

func (cf *CardMessageFuture) Error() error

func (*CardMessageFuture) Receive

func (cf *CardMessageFuture) Receive() *CardMessage

func (*CardMessageFuture) Return

func (cf *CardMessageFuture) Return(out *CardMessage)

type CardMessage_Type

type CardMessage_Type int32

const (
	CardMessage_ACK  CardMessage_Type = 0
	CardMessage_ACK2 CardMessage_Type = 1
	CardMessage_ACK3 CardMessage_Type = 2
	CardMessage_SYNC CardMessage_Type = 3
)

func (CardMessage_Type) EnumDescriptor

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

func (CardMessage_Type) String

func (x CardMessage_Type) String() string

type Digest

type Digest digest.Digest

Digest from public import github.com/GoCollaborate/src/artifacts/digest/digest.proto

func (*Digest) GetCards

func (m *Digest) GetCards() map[string]*Card

func (*Digest) GetTs

func (m *Digest) GetTs() int64

func (*Digest) ProtoMessage

func (*Digest) ProtoMessage()

func (*Digest) Reset

func (m *Digest) Reset()

func (*Digest) String

func (m *Digest) String() string

type Status

type Status struct {
	Key   string `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value" json:"value,omitempty"`
}

func (*Status) Descriptor

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

func (*Status) GetKey

func (m *Status) GetKey() string

func (*Status) GetValue

func (m *Status) GetValue() string

func (*Status) ProtoMessage

func (*Status) ProtoMessage()

func (*Status) Reset

func (m *Status) Reset()

func (*Status) String

func (m *Status) String() string