protobuf

package
v0.0.0-...-1e7855a Latest Latest
Warning

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

Go to latest
Published: May 6, 2016 License: MIT Imports: 5 Imported by: 1

Documentation

Overview

Package protobuf is a generated protocol buffer package.

It is generated from these files:

src/datamodel/protobuf/skizze.proto

It has these top-level messages:

Empty
SketchProperties
SketchState
Domain
Sketch
Membership
Frequency
Rank
CreateSnapshotRequest
CreateSnapshotReply
GetSnapshotRequest
GetSnapshotReply
ListRequest
ListReply
ListDomainsReply
AddRequest
AddReply
GetRequest
MembershipResult
FrequencyResult
CardinalityResult
RankingsResult
GetMembershipReply
GetFrequencyReply
GetCardinalityReply
GetRankingsReply

Index

Constants

This section is empty.

Variables

View Source
var SketchType_name = map[int32]string{
	1: "MEMB",
	2: "FREQ",
	3: "RANK",
	4: "CARD",
}
View Source
var SketchType_value = map[string]int32{
	"MEMB": 1,
	"FREQ": 2,
	"RANK": 3,
	"CARD": 4,
}
View Source
var SnapshotStatus_name = map[int32]string{
	1: "PENDING",
	2: "IN_PROGRESS",
	3: "SUCCESSFUL",
	4: "FAILED",
}
View Source
var SnapshotStatus_value = map[string]int32{
	"PENDING":     1,
	"IN_PROGRESS": 2,
	"SUCCESSFUL":  3,
	"FAILED":      4,
}

Functions

func RegisterSkizzeServer

func RegisterSkizzeServer(s *grpc.Server, srv SkizzeServer)

Types

type AddReply

type AddReply struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*AddReply) Descriptor

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

func (*AddReply) ProtoMessage

func (*AddReply) ProtoMessage()

func (*AddReply) Reset

func (m *AddReply) Reset()

func (*AddReply) String

func (m *AddReply) String() string

type AddRequest

type AddRequest struct {
	Domain           *Domain  `protobuf:"bytes,1,opt,name=domain" json:"domain,omitempty"`
	Sketch           *Sketch  `protobuf:"bytes,2,opt,name=sketch" json:"sketch,omitempty"`
	Values           []string `protobuf:"bytes,3,rep,name=values" json:"values,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*AddRequest) Descriptor

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

func (*AddRequest) GetDomain

func (m *AddRequest) GetDomain() *Domain

func (*AddRequest) GetSketch

func (m *AddRequest) GetSketch() *Sketch

func (*AddRequest) GetValues

func (m *AddRequest) GetValues() []string

func (*AddRequest) ProtoMessage

func (*AddRequest) ProtoMessage()

func (*AddRequest) Reset

func (m *AddRequest) Reset()

func (*AddRequest) String

func (m *AddRequest) String() string

type CardinalityResult

type CardinalityResult struct {
	Cardinality      *int64 `protobuf:"varint,1,req,name=cardinality" json:"cardinality,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*CardinalityResult) Descriptor

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

func (*CardinalityResult) GetCardinality

func (m *CardinalityResult) GetCardinality() int64

func (*CardinalityResult) ProtoMessage

func (*CardinalityResult) ProtoMessage()

func (*CardinalityResult) Reset

func (m *CardinalityResult) Reset()

func (*CardinalityResult) String

func (m *CardinalityResult) String() string

type CreateSnapshotReply

type CreateSnapshotReply struct {
	Status           *SnapshotStatus `protobuf:"varint,1,req,name=status,enum=protobuf.SnapshotStatus" json:"status,omitempty"`
	StatusMessage    *string         `protobuf:"bytes,2,opt,name=statusMessage" json:"statusMessage,omitempty"`
	XXX_unrecognized []byte          `json:"-"`
}

func (*CreateSnapshotReply) Descriptor

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

func (*CreateSnapshotReply) GetStatus

func (m *CreateSnapshotReply) GetStatus() SnapshotStatus

func (*CreateSnapshotReply) GetStatusMessage

func (m *CreateSnapshotReply) GetStatusMessage() string

func (*CreateSnapshotReply) ProtoMessage

func (*CreateSnapshotReply) ProtoMessage()

func (*CreateSnapshotReply) Reset

func (m *CreateSnapshotReply) Reset()

func (*CreateSnapshotReply) String

func (m *CreateSnapshotReply) String() string

type CreateSnapshotRequest

type CreateSnapshotRequest struct {
	XXX_unrecognized []byte `json:"-"`
}

Right now empty but in the future can request specific snapshot location (e.g. S3 or disk) and snapshot options

func (*CreateSnapshotRequest) Descriptor

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

func (*CreateSnapshotRequest) ProtoMessage

func (*CreateSnapshotRequest) ProtoMessage()

func (*CreateSnapshotRequest) Reset

func (m *CreateSnapshotRequest) Reset()

func (*CreateSnapshotRequest) String

func (m *CreateSnapshotRequest) String() string

type Domain

type Domain struct {
	Name             *string   `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
	Sketches         []*Sketch `protobuf:"bytes,2,rep,name=sketches" json:"sketches,omitempty"`
	XXX_unrecognized []byte    `json:"-"`
}

CreateDomain: name:required, propertiess:optional (array = nSketchTypes, order of types above) DeleteDomain: name:required GetDomain : name:required

func (*Domain) Descriptor

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

func (*Domain) GetName

func (m *Domain) GetName() string

func (*Domain) GetSketches

func (m *Domain) GetSketches() []*Sketch

func (*Domain) ProtoMessage

func (*Domain) ProtoMessage()

func (*Domain) Reset

func (m *Domain) Reset()

func (*Domain) String

func (m *Domain) String() string

type Empty

type Empty struct {
	XXX_unrecognized []byte `json:"-"`
}

Generic Structures

func (*Empty) Descriptor

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

func (*Empty) ProtoMessage

func (*Empty) ProtoMessage()

func (*Empty) Reset

func (m *Empty) Reset()

func (*Empty) String

func (m *Empty) String() string

type Frequency

type Frequency struct {
	Value            *string `protobuf:"bytes,1,req,name=value" json:"value,omitempty"`
	Count            *int64  `protobuf:"varint,2,req,name=count" json:"count,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*Frequency) Descriptor

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

func (*Frequency) GetCount

func (m *Frequency) GetCount() int64

func (*Frequency) GetValue

func (m *Frequency) GetValue() string

func (*Frequency) ProtoMessage

func (*Frequency) ProtoMessage()

func (*Frequency) Reset

func (m *Frequency) Reset()

func (*Frequency) String

func (m *Frequency) String() string

type FrequencyResult

type FrequencyResult struct {
	Frequencies      []*Frequency `protobuf:"bytes,2,rep,name=frequencies" json:"frequencies,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

func (*FrequencyResult) Descriptor

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

func (*FrequencyResult) GetFrequencies

func (m *FrequencyResult) GetFrequencies() []*Frequency

func (*FrequencyResult) ProtoMessage

func (*FrequencyResult) ProtoMessage()

func (*FrequencyResult) Reset

func (m *FrequencyResult) Reset()

func (*FrequencyResult) String

func (m *FrequencyResult) String() string

type GetCardinalityReply

type GetCardinalityReply struct {
	Results          []*CardinalityResult `protobuf:"bytes,1,rep,name=results" json:"results,omitempty"`
	XXX_unrecognized []byte               `json:"-"`
}

func (*GetCardinalityReply) Descriptor

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

func (*GetCardinalityReply) GetResults

func (m *GetCardinalityReply) GetResults() []*CardinalityResult

func (*GetCardinalityReply) ProtoMessage

func (*GetCardinalityReply) ProtoMessage()

func (*GetCardinalityReply) Reset

func (m *GetCardinalityReply) Reset()

func (*GetCardinalityReply) String

func (m *GetCardinalityReply) String() string

type GetFrequencyReply

type GetFrequencyReply struct {
	Results          []*FrequencyResult `protobuf:"bytes,1,rep,name=results" json:"results,omitempty"`
	XXX_unrecognized []byte             `json:"-"`
}

func (*GetFrequencyReply) Descriptor

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

func (*GetFrequencyReply) GetResults

func (m *GetFrequencyReply) GetResults() []*FrequencyResult

func (*GetFrequencyReply) ProtoMessage

func (*GetFrequencyReply) ProtoMessage()

func (*GetFrequencyReply) Reset

func (m *GetFrequencyReply) Reset()

func (*GetFrequencyReply) String

func (m *GetFrequencyReply) String() string

type GetMembershipReply

type GetMembershipReply struct {
	Results          []*MembershipResult `protobuf:"bytes,1,rep,name=results" json:"results,omitempty"`
	XXX_unrecognized []byte              `json:"-"`
}

func (*GetMembershipReply) Descriptor

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

func (*GetMembershipReply) GetResults

func (m *GetMembershipReply) GetResults() []*MembershipResult

func (*GetMembershipReply) ProtoMessage

func (*GetMembershipReply) ProtoMessage()

func (*GetMembershipReply) Reset

func (m *GetMembershipReply) Reset()

func (*GetMembershipReply) String

func (m *GetMembershipReply) String() string

type GetRankingsReply

type GetRankingsReply struct {
	Results          []*RankingsResult `protobuf:"bytes,1,rep,name=results" json:"results,omitempty"`
	XXX_unrecognized []byte            `json:"-"`
}

func (*GetRankingsReply) Descriptor

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

func (*GetRankingsReply) GetResults

func (m *GetRankingsReply) GetResults() []*RankingsResult

func (*GetRankingsReply) ProtoMessage

func (*GetRankingsReply) ProtoMessage()

func (*GetRankingsReply) Reset

func (m *GetRankingsReply) Reset()

func (*GetRankingsReply) String

func (m *GetRankingsReply) String() string

type GetRequest

type GetRequest struct {
	Sketches         []*Sketch `protobuf:"bytes,1,rep,name=sketches" json:"sketches,omitempty"`
	Values           []string  `protobuf:"bytes,2,rep,name=values" json:"values,omitempty"`
	XXX_unrecognized []byte    `json:"-"`
}

All Sketches will be of one kind All values will apply to all sketches (if card or ranking, values will be ignored)

func (*GetRequest) Descriptor

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

func (*GetRequest) GetSketches

func (m *GetRequest) GetSketches() []*Sketch

func (*GetRequest) GetValues

func (m *GetRequest) GetValues() []string

func (*GetRequest) ProtoMessage

func (*GetRequest) ProtoMessage()

func (*GetRequest) Reset

func (m *GetRequest) Reset()

func (*GetRequest) String

func (m *GetRequest) String() string

type GetSnapshotReply

type GetSnapshotReply struct {
	Status           *SnapshotStatus `protobuf:"varint,1,req,name=status,enum=protobuf.SnapshotStatus" json:"status,omitempty"`
	StatusMessage    *string         `protobuf:"bytes,2,opt,name=statusMessage" json:"statusMessage,omitempty"`
	Timestamp        *int64          `protobuf:"varint,3,opt,name=timestamp" json:"timestamp,omitempty"`
	XXX_unrecognized []byte          `json:"-"`
}

func (*GetSnapshotReply) Descriptor

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

func (*GetSnapshotReply) GetStatus

func (m *GetSnapshotReply) GetStatus() SnapshotStatus

func (*GetSnapshotReply) GetStatusMessage

func (m *GetSnapshotReply) GetStatusMessage() string

func (*GetSnapshotReply) GetTimestamp

func (m *GetSnapshotReply) GetTimestamp() int64

func (*GetSnapshotReply) ProtoMessage

func (*GetSnapshotReply) ProtoMessage()

func (*GetSnapshotReply) Reset

func (m *GetSnapshotReply) Reset()

func (*GetSnapshotReply) String

func (m *GetSnapshotReply) String() string

type GetSnapshotRequest

type GetSnapshotRequest struct {
	XXX_unrecognized []byte `json:"-"`
}

Empty for now, future can send in id of specific snapshot

func (*GetSnapshotRequest) Descriptor

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

func (*GetSnapshotRequest) ProtoMessage

func (*GetSnapshotRequest) ProtoMessage()

func (*GetSnapshotRequest) Reset

func (m *GetSnapshotRequest) Reset()

func (*GetSnapshotRequest) String

func (m *GetSnapshotRequest) String() string

type ListDomainsReply

type ListDomainsReply struct {
	Names            []string `protobuf:"bytes,1,rep,name=names" json:"names,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*ListDomainsReply) Descriptor

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

func (*ListDomainsReply) GetNames

func (m *ListDomainsReply) GetNames() []string

func (*ListDomainsReply) ProtoMessage

func (*ListDomainsReply) ProtoMessage()

func (*ListDomainsReply) Reset

func (m *ListDomainsReply) Reset()

func (*ListDomainsReply) String

func (m *ListDomainsReply) String() string

type ListReply

type ListReply struct {
	Sketches         []*Sketch `protobuf:"bytes,1,rep,name=sketches" json:"sketches,omitempty"`
	XXX_unrecognized []byte    `json:"-"`
}

func (*ListReply) Descriptor

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

func (*ListReply) GetSketches

func (m *ListReply) GetSketches() []*Sketch

func (*ListReply) ProtoMessage

func (*ListReply) ProtoMessage()

func (*ListReply) Reset

func (m *ListReply) Reset()

func (*ListReply) String

func (m *ListReply) String() string

type ListRequest

type ListRequest struct {
	Type             *SketchType `protobuf:"varint,1,req,name=type,enum=protobuf.SketchType" json:"type,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

func (*ListRequest) Descriptor

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

func (*ListRequest) GetType

func (m *ListRequest) GetType() SketchType

func (*ListRequest) ProtoMessage

func (*ListRequest) ProtoMessage()

func (*ListRequest) Reset

func (m *ListRequest) Reset()

func (*ListRequest) String

func (m *ListRequest) String() string

type Membership

type Membership struct {
	Value            *string `protobuf:"bytes,1,req,name=value" json:"value,omitempty"`
	IsMember         *bool   `protobuf:"varint,2,req,name=isMember" json:"isMember,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*Membership) Descriptor

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

func (*Membership) GetIsMember

func (m *Membership) GetIsMember() bool

func (*Membership) GetValue

func (m *Membership) GetValue() string

func (*Membership) ProtoMessage

func (*Membership) ProtoMessage()

func (*Membership) Reset

func (m *Membership) Reset()

func (*Membership) String

func (m *Membership) String() string

type MembershipResult

type MembershipResult struct {
	Memberships      []*Membership `protobuf:"bytes,1,rep,name=memberships" json:"memberships,omitempty"`
	XXX_unrecognized []byte        `json:"-"`
}

func (*MembershipResult) Descriptor

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

func (*MembershipResult) GetMemberships

func (m *MembershipResult) GetMemberships() []*Membership

func (*MembershipResult) ProtoMessage

func (*MembershipResult) ProtoMessage()

func (*MembershipResult) Reset

func (m *MembershipResult) Reset()

func (*MembershipResult) String

func (m *MembershipResult) String() string

type Rank

type Rank struct {
	Value            *string `protobuf:"bytes,1,req,name=value" json:"value,omitempty"`
	Count            *int64  `protobuf:"varint,2,req,name=count" json:"count,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*Rank) Descriptor

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

func (*Rank) GetCount

func (m *Rank) GetCount() int64

func (*Rank) GetValue

func (m *Rank) GetValue() string

func (*Rank) ProtoMessage

func (*Rank) ProtoMessage()

func (*Rank) Reset

func (m *Rank) Reset()

func (*Rank) String

func (m *Rank) String() string

type RankingsResult

type RankingsResult struct {
	Rankings         []*Rank `protobuf:"bytes,1,rep,name=rankings" json:"rankings,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*RankingsResult) Descriptor

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

func (*RankingsResult) GetRankings

func (m *RankingsResult) GetRankings() []*Rank

func (*RankingsResult) ProtoMessage

func (*RankingsResult) ProtoMessage()

func (*RankingsResult) Reset

func (m *RankingsResult) Reset()

func (*RankingsResult) String

func (m *RankingsResult) String() string

type Sketch

type Sketch struct {
	Name             *string           `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
	Type             *SketchType       `protobuf:"varint,2,req,name=type,enum=protobuf.SketchType" json:"type,omitempty"`
	Properties       *SketchProperties `protobuf:"bytes,3,opt,name=properties" json:"properties,omitempty"`
	State            *SketchState      `protobuf:"bytes,4,opt,name=state" json:"state,omitempty"`
	XXX_unrecognized []byte            `json:"-"`
}

CreateSketch: name:required, type:required, properties:optional DeleteSketch: name:required, type:required GetSketch : name:required, type:required

func (*Sketch) Descriptor

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

func (*Sketch) GetName

func (m *Sketch) GetName() string

func (*Sketch) GetProperties

func (m *Sketch) GetProperties() *SketchProperties

func (*Sketch) GetState

func (m *Sketch) GetState() *SketchState

func (*Sketch) GetType

func (m *Sketch) GetType() SketchType

func (*Sketch) ProtoMessage

func (*Sketch) ProtoMessage()

func (*Sketch) Reset

func (m *Sketch) Reset()

func (*Sketch) String

func (m *Sketch) String() string

type SketchProperties

type SketchProperties struct {
	MaxUniqueItems   *int64   `protobuf:"varint,1,opt,name=maxUniqueItems" json:"maxUniqueItems,omitempty"`
	ErrorRate        *float32 `protobuf:"fixed32,2,opt,name=errorRate" json:"errorRate,omitempty"`
	Size             *int64   `protobuf:"varint,3,opt,name=size" json:"size,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*SketchProperties) Descriptor

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

func (*SketchProperties) GetErrorRate

func (m *SketchProperties) GetErrorRate() float32

func (*SketchProperties) GetMaxUniqueItems

func (m *SketchProperties) GetMaxUniqueItems() int64

func (*SketchProperties) GetSize

func (m *SketchProperties) GetSize() int64

func (*SketchProperties) ProtoMessage

func (*SketchProperties) ProtoMessage()

func (*SketchProperties) Reset

func (m *SketchProperties) Reset()

func (*SketchProperties) String

func (m *SketchProperties) String() string

type SketchState

type SketchState struct {
	FillRate         *float32 `protobuf:"fixed32,1,opt,name=fillRate" json:"fillRate,omitempty"`
	LastSnapshot     *int64   `protobuf:"varint,2,opt,name=lastSnapshot" json:"lastSnapshot,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*SketchState) Descriptor

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

func (*SketchState) GetFillRate

func (m *SketchState) GetFillRate() float32

func (*SketchState) GetLastSnapshot

func (m *SketchState) GetLastSnapshot() int64

func (*SketchState) ProtoMessage

func (*SketchState) ProtoMessage()

func (*SketchState) Reset

func (m *SketchState) Reset()

func (*SketchState) String

func (m *SketchState) String() string

type SketchType

type SketchType int32

Enums

const (
	SketchType_MEMB SketchType = 1
	SketchType_FREQ SketchType = 2
	SketchType_RANK SketchType = 3
	SketchType_CARD SketchType = 4
)

func (SketchType) Enum

func (x SketchType) Enum() *SketchType

func (SketchType) EnumDescriptor

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

func (SketchType) String

func (x SketchType) String() string

func (*SketchType) UnmarshalJSON

func (x *SketchType) UnmarshalJSON(data []byte) error

type SkizzeClient

type SkizzeClient interface {
	CreateSnapshot(ctx context.Context, in *CreateSnapshotRequest, opts ...grpc.CallOption) (*CreateSnapshotReply, error)
	GetSnapshot(ctx context.Context, in *GetSnapshotRequest, opts ...grpc.CallOption) (*GetSnapshotReply, error)
	List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListReply, error)
	ListAll(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ListReply, error)
	ListDomains(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ListDomainsReply, error)
	CreateDomain(ctx context.Context, in *Domain, opts ...grpc.CallOption) (*Domain, error)
	DeleteDomain(ctx context.Context, in *Domain, opts ...grpc.CallOption) (*Empty, error)
	GetDomain(ctx context.Context, in *Domain, opts ...grpc.CallOption) (*Domain, error)
	CreateSketch(ctx context.Context, in *Sketch, opts ...grpc.CallOption) (*Sketch, error)
	DeleteSketch(ctx context.Context, in *Sketch, opts ...grpc.CallOption) (*Empty, error)
	GetSketch(ctx context.Context, in *Sketch, opts ...grpc.CallOption) (*Sketch, error)
	Add(ctx context.Context, in *AddRequest, opts ...grpc.CallOption) (*AddReply, error)
	GetMembership(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetMembershipReply, error)
	GetFrequency(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetFrequencyReply, error)
	GetCardinality(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetCardinalityReply, error)
	GetRankings(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetRankingsReply, error)
}

func NewSkizzeClient

func NewSkizzeClient(cc *grpc.ClientConn) SkizzeClient

type SnapshotStatus

type SnapshotStatus int32
const (
	SnapshotStatus_PENDING     SnapshotStatus = 1
	SnapshotStatus_IN_PROGRESS SnapshotStatus = 2
	SnapshotStatus_SUCCESSFUL  SnapshotStatus = 3
	SnapshotStatus_FAILED      SnapshotStatus = 4
)

func (SnapshotStatus) Enum

func (x SnapshotStatus) Enum() *SnapshotStatus

func (SnapshotStatus) EnumDescriptor

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

func (SnapshotStatus) String

func (x SnapshotStatus) String() string

func (*SnapshotStatus) UnmarshalJSON

func (x *SnapshotStatus) UnmarshalJSON(data []byte) error

Jump to

Keyboard shortcuts

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