types

package
v0.0.0-...-59ab172 Latest Latest
Warning

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

 Go to latest Published: Sep 8, 2020 License: Apache-2.0 Imports: 9 Imported by: 0

README

Cryptomood b2b client - golang

Client example

  1. When connecting to the server use x509 cert.pem file located in certs directory. You won't be able to access the server without it

  2. Make sure you have at least the latest stable version of Golang

  3. (optional) install protoc tool and protoc-gen-go

  4. (optional) transpile proto file to *.go file with protoc -I .. -I $GOPATH/src --go_out=plugins=grpc:./ ../types.proto This will generate transpiled file into current directory. To adhere golang conventions and also to make these examples work, compiler should be able to find this file. Otherwise put it into your GOPATH directory ($GOPATH/src/types) and then just import it like import types.

    Steps 3-4 are optional, because this directory already contains prepared types.pb.go file

  5. Load credentials

    creds, err := credentials.NewClientTLSFromFile(CertFile, "")

  6. Dial the server. You must provide your api token (to obtain it visit our website) to authorize your requests

    conn, err := grpc.Dial(Server, grpc.WithTransportCredentials(creds), grpc.WithPerRPCCredentials(tokenAuth{Token}), grpc.WithTimeout(5*time.Second), grpc.WithBlock())

  7. Initialize required service and call required method (in this case subscription)

    proxyClient := types.NewMessagesProxyClient(conn)
sub, err := proxyClient.SubscribeTweet(context.Background(), &empty.Empty{})

  8. Read data indefinitely

    for {
		msg, err := sub.Recv()
		if err == io.EOF {
			continue
		}
		if sub.Context().Err() != nil {
			_ = sub.CloseSend()
			fmt.Println("Closing connection to server")
			break
		}
		fmt.Println(msg.Base.Content, err)
	}

For full example, see any example directory.

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var NamedEntity_name = map[int32]string{
	0: "ASSET_ENTITY",
	1: "PERSON_ENTITY",
	2: "LOCATION_ENTITY",
	3: "COMPANY_ENTITY",
	4: "EXCHANGE_ENTITY",
	5: "MISC_ENTITY",
	6: "ORGANIZATION_ENTITY",
}
View Source 
var NamedEntity_value = map[string]int32{
	"ASSET_ENTITY":        0,
	"PERSON_ENTITY":       1,
	"LOCATION_ENTITY":     2,
	"COMPANY_ENTITY":      3,
	"EXCHANGE_ENTITY":     4,
	"MISC_ENTITY":         5,
	"ORGANIZATION_ENTITY": 6,
}

Functions

func RegisterDatasetServer 

func RegisterDatasetServer(s *grpc.Server, srv DatasetServer)

func RegisterHistoricDataServer 

func RegisterHistoricDataServer(s *grpc.Server, srv HistoricDataServer)

func RegisterMessagesProxyServer 

func RegisterMessagesProxyServer(s *grpc.Server, srv MessagesProxyServer)

func RegisterSentimentsServer 

func RegisterSentimentsServer(s *grpc.Server, srv SentimentsServer)

Types

type AggId 

type AggId struct {
	Year                 int32    `protobuf:"varint,1,opt,name=year,proto3" json:"year,omitempty"`
	Month                int32    `protobuf:"varint,2,opt,name=month,proto3" json:"month,omitempty"`
	Day                  int32    `protobuf:"varint,3,opt,name=day,proto3" json:"day,omitempty"`
	Hour                 int32    `protobuf:"varint,4,opt,name=hour,proto3" json:"hour,omitempty"`
	Minute               int32    `protobuf:"varint,5,opt,name=minute,proto3" json:"minute,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AggId) Descriptor 

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

func (*AggId) GetDay 

func (m *AggId) GetDay() int32

func (*AggId) GetHour 

func (m *AggId) GetHour() int32

func (*AggId) GetMinute 

func (m *AggId) GetMinute() int32

func (*AggId) GetMonth 

func (m *AggId) GetMonth() int32

func (*AggId) GetYear 

func (m *AggId) GetYear() int32

func (*AggId) ProtoMessage 

func (*AggId) ProtoMessage()

func (*AggId) Reset 

func (m *AggId) Reset()

func (*AggId) String 

func (m *AggId) String() string

func (*AggId) XXX_DiscardUnknown 

func (m *AggId) XXX_DiscardUnknown()

func (*AggId) XXX_Marshal 

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

func (*AggId) XXX_Merge 

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

func (*AggId) XXX_Size 

func (m *AggId) XXX_Size() int

func (*AggId) XXX_Unmarshal 

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

type AggregationCandle 

type AggregationCandle struct {
	Id                   *AggId   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Asset                string   `protobuf:"bytes,2,opt,name=asset,proto3" json:"asset,omitempty"`
	Resolution           string   `protobuf:"bytes,3,opt,name=resolution,proto3" json:"resolution,omitempty"`
	Pv                   int64    `protobuf:"varint,4,opt,name=pv,proto3" json:"pv,omitempty"`
	Nv                   int64    `protobuf:"varint,5,opt,name=nv,proto3" json:"nv,omitempty"`
	Ps                   float64  `protobuf:"fixed64,6,opt,name=ps,proto3" json:"ps,omitempty"`
	Ns                   float64  `protobuf:"fixed64,7,opt,name=ns,proto3" json:"ns,omitempty"`
	A                    float64  `protobuf:"fixed64,8,opt,name=a,proto3" json:"a,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AggregationCandle) Descriptor 

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

func (*AggregationCandle) GetA 

func (m *AggregationCandle) GetA() float64

func (*AggregationCandle) GetAsset 

func (m *AggregationCandle) GetAsset() string

func (*AggregationCandle) GetId 

func (m *AggregationCandle) GetId() *AggId

func (*AggregationCandle) GetNs 

func (m *AggregationCandle) GetNs() float64

func (*AggregationCandle) GetNv 

func (m *AggregationCandle) GetNv() int64

func (*AggregationCandle) GetPs 

func (m *AggregationCandle) GetPs() float64

func (*AggregationCandle) GetPv 

func (m *AggregationCandle) GetPv() int64

func (*AggregationCandle) GetResolution 

func (m *AggregationCandle) GetResolution() string

func (*AggregationCandle) ProtoMessage 

func (*AggregationCandle) ProtoMessage()

func (*AggregationCandle) Reset 

func (m *AggregationCandle) Reset()

func (*AggregationCandle) String 

func (m *AggregationCandle) String() string

func (*AggregationCandle) XXX_DiscardUnknown 

func (m *AggregationCandle) XXX_DiscardUnknown()

func (*AggregationCandle) XXX_Marshal 

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

func (*AggregationCandle) XXX_Merge 

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

func (*AggregationCandle) XXX_Size 

func (m *AggregationCandle) XXX_Size() int

func (*AggregationCandle) XXX_Unmarshal 

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

type AggregationCandleFilter 

type AggregationCandleFilter struct {
	// resolution for candle - M1/H1
	Resolution           string        `protobuf:"bytes,1,opt,name=resolution,proto3" json:"resolution,omitempty"`
	AssetsFilter         *AssetsFilter `protobuf:"bytes,2,opt,name=assets_filter,json=assetsFilter,proto3" json:"assets_filter,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*AggregationCandleFilter) Descriptor 

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

func (*AggregationCandleFilter) GetAssetsFilter 

func (m *AggregationCandleFilter) GetAssetsFilter() *AssetsFilter

func (*AggregationCandleFilter) GetResolution 

func (m *AggregationCandleFilter) GetResolution() string

func (*AggregationCandleFilter) ProtoMessage 

func (*AggregationCandleFilter) ProtoMessage()

func (*AggregationCandleFilter) Reset 

func (m *AggregationCandleFilter) Reset()

func (*AggregationCandleFilter) String 

func (m *AggregationCandleFilter) String() string

func (*AggregationCandleFilter) XXX_DiscardUnknown 

func (m *AggregationCandleFilter) XXX_DiscardUnknown()

func (*AggregationCandleFilter) XXX_Marshal 

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

func (*AggregationCandleFilter) XXX_Merge 

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

func (*AggregationCandleFilter) XXX_Size 

func (m *AggregationCandleFilter) XXX_Size() int

func (*AggregationCandleFilter) XXX_Unmarshal 

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

type Article 

type Article struct {
	Base      *BaseModel      `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	Sentiment *SentimentModel `protobuf:"bytes,2,opt,name=sentiment,proto3" json:"sentiment,omitempty"`
	// named entities from content
	NamedEntities *NamedEntitiesModel `protobuf:"bytes,3,opt,name=named_entities,json=namedEntities,proto3" json:"named_entities,omitempty"`
	// named entities from title
	TitleData            *NamedEntitiesModel `protobuf:"bytes,4,opt,name=title_data,json=titleData,proto3" json:"title_data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

* Basic model for News, articles. It's weight depends on Alexa ranks

func (*Article) Descriptor 

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

func (*Article) GetBase 

func (m *Article) GetBase() *BaseModel

func (*Article) GetNamedEntities 

func (m *Article) GetNamedEntities() *NamedEntitiesModel

func (*Article) GetSentiment 

func (m *Article) GetSentiment() *SentimentModel

func (*Article) GetTitleData 

func (m *Article) GetTitleData() *NamedEntitiesModel

func (*Article) ProtoMessage 

func (*Article) ProtoMessage()

func (*Article) Reset 

func (m *Article) Reset()

func (*Article) String 

func (m *Article) String() string

func (*Article) XXX_DiscardUnknown 

func (m *Article) XXX_DiscardUnknown()

func (*Article) XXX_Marshal 

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

func (*Article) XXX_Merge 

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

func (*Article) XXX_Size 

func (m *Article) XXX_Size() int

func (*Article) XXX_Unmarshal 

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

type Asset 

type Asset struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// symbol can be duplicated throughout the db
	Symbol string `protobuf:"bytes,2,opt,name=symbol,proto3" json:"symbol,omitempty"`
	// unique field
	Code                 string   `protobuf:"bytes,3,opt,name=code,proto3" json:"code,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

* Represent one asset.

func (*Asset) Descriptor 

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

func (*Asset) GetCode 

func (m *Asset) GetCode() string

func (*Asset) GetName 

func (m *Asset) GetName() string

func (*Asset) GetSymbol 

func (m *Asset) GetSymbol() string

func (*Asset) ProtoMessage 

func (*Asset) ProtoMessage()

func (*Asset) Reset 

func (m *Asset) Reset()

func (*Asset) String 

func (m *Asset) String() string

func (*Asset) XXX_DiscardUnknown 

func (m *Asset) XXX_DiscardUnknown()

func (*Asset) XXX_Marshal 

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

func (*Asset) XXX_Merge 

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

func (*Asset) XXX_Size 

func (m *Asset) XXX_Size() int

func (*Asset) XXX_Unmarshal 

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

type AssetItems 

type AssetItems struct {
	Assets               []*Asset `protobuf:"bytes,1,rep,name=assets,proto3" json:"assets,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AssetItems) Descriptor 

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

func (*AssetItems) GetAssets 

func (m *AssetItems) GetAssets() []*Asset

func (*AssetItems) ProtoMessage 

func (*AssetItems) ProtoMessage()

func (*AssetItems) Reset 

func (m *AssetItems) Reset()

func (*AssetItems) String 

func (m *AssetItems) String() string

func (*AssetItems) XXX_DiscardUnknown 

func (m *AssetItems) XXX_DiscardUnknown()

func (*AssetItems) XXX_Marshal 

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

func (*AssetItems) XXX_Merge 

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

func (*AssetItems) XXX_Size 

func (m *AssetItems) XXX_Size() int

func (*AssetItems) XXX_Unmarshal 

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

type AssetsFilter 

type AssetsFilter struct {
	// name of the asset - ie. BTC
	Assets               []string `protobuf:"bytes,4,rep,name=assets,proto3" json:"assets,omitempty"`
	AllAssets            bool     `protobuf:"varint,5,opt,name=all_assets,json=allAssets,proto3" json:"all_assets,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AssetsFilter) Descriptor 

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

func (*AssetsFilter) GetAllAssets 

func (m *AssetsFilter) GetAllAssets() bool

func (*AssetsFilter) GetAssets 

func (m *AssetsFilter) GetAssets() []string

func (*AssetsFilter) ProtoMessage 

func (*AssetsFilter) ProtoMessage()

func (*AssetsFilter) Reset 

func (m *AssetsFilter) Reset()

func (*AssetsFilter) String 

func (m *AssetsFilter) String() string

func (*AssetsFilter) XXX_DiscardUnknown 

func (m *AssetsFilter) XXX_DiscardUnknown()

func (*AssetsFilter) XXX_Marshal 

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

func (*AssetsFilter) XXX_Merge 

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

func (*AssetsFilter) XXX_Size 

func (m *AssetsFilter) XXX_Size() int

func (*AssetsFilter) XXX_Unmarshal 

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

type BaseModel 

type BaseModel struct {
	// unique identifier with schema
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// title of article
	Title string `protobuf:"bytes,2,opt,name=title,proto3" json:"title,omitempty"`
	// full content stripped of unnecessary characters(js, html tags...)
	Content string `protobuf:"bytes,3,opt,name=content,proto3" json:"content,omitempty"`
	//
	Crawler string `protobuf:"bytes,4,opt,name=crawler,proto3" json:"crawler,omitempty"`
	// timestamp representing the datetime, when the article has been published
	PubDate *timestamp.Timestamp `protobuf:"bytes,5,opt,name=pub_date,json=pubDate,proto3" json:"pub_date,omitempty"`
	// timestamp representing acquisition datetime
	Created *timestamp.Timestamp `protobuf:"bytes,6,opt,name=created,proto3" json:"created,omitempty"`
	// url of article
	Source string `protobuf:"bytes,7,opt,name=source,proto3" json:"source,omitempty"`
	// summary provided by the domain
	Excerpt string `protobuf:"bytes,8,opt,name=excerpt,proto3" json:"excerpt,omitempty"`
	// list of video sources
	Videos []string `protobuf:"bytes,9,rep,name=videos,proto3" json:"videos,omitempty"`
	// list of image sources
	Images []string `protobuf:"bytes,10,rep,name=images,proto3" json:"images,omitempty"`
	// list of off-page hyperlinks
	Links []string `protobuf:"bytes,11,rep,name=links,proto3" json:"links,omitempty"`
	// author of article
	Author string `protobuf:"bytes,12,opt,name=author,proto3" json:"author,omitempty"`
	// identified language
	Lang string `protobuf:"bytes,13,opt,name=lang,proto3" json:"lang,omitempty"`
	// importance of the article's creator
	Weight float64 `protobuf:"fixed64,14,opt,name=weight,proto3" json:"weight,omitempty"`
	// measured spam value
	Spam                 float64  `protobuf:"fixed64,15,opt,name=spam,proto3" json:"spam,omitempty"`
	Domain               string   `protobuf:"bytes,16,opt,name=domain,proto3" json:"domain,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

* Base model for messages or news, contains basic data like title, content, source, published date etc..

func (*BaseModel) Descriptor 

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

func (*BaseModel) GetAuthor 

func (m *BaseModel) GetAuthor() string

func (*BaseModel) GetContent 

func (m *BaseModel) GetContent() string

func (*BaseModel) GetCrawler 

func (m *BaseModel) GetCrawler() string

func (*BaseModel) GetCreated 

func (m *BaseModel) GetCreated() *timestamp.Timestamp

func (*BaseModel) GetDomain 

func (m *BaseModel) GetDomain() string

func (*BaseModel) GetExcerpt 

func (m *BaseModel) GetExcerpt() string

func (*BaseModel) GetId 

func (m *BaseModel) GetId() string

func (*BaseModel) GetImages 

func (m *BaseModel) GetImages() []string

func (*BaseModel) GetLang 

func (m *BaseModel) GetLang() string
func (m *BaseModel) GetLinks() []string

func (*BaseModel) GetPubDate 

func (m *BaseModel) GetPubDate() *timestamp.Timestamp

func (*BaseModel) GetSource 

func (m *BaseModel) GetSource() string

func (*BaseModel) GetSpam 

func (m *BaseModel) GetSpam() float64

func (*BaseModel) GetTitle 

func (m *BaseModel) GetTitle() string

func (*BaseModel) GetVideos 

func (m *BaseModel) GetVideos() []string

func (*BaseModel) GetWeight 

func (m *BaseModel) GetWeight() float64

func (*BaseModel) ProtoMessage 

func (*BaseModel) ProtoMessage()

func (*BaseModel) Reset 

func (m *BaseModel) Reset()

func (*BaseModel) String 

func (m *BaseModel) String() string

func (*BaseModel) XXX_DiscardUnknown 

func (m *BaseModel) XXX_DiscardUnknown()

func (*BaseModel) XXX_Marshal 

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

func (*BaseModel) XXX_Merge 

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

func (*BaseModel) XXX_Size 

func (m *BaseModel) XXX_Size() int

func (*BaseModel) XXX_Unmarshal 

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

type CryptopanicEntryMetadata 

type CryptopanicEntryMetadata struct {
	Message              string   `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	Description          string   `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CryptopanicEntryMetadata) Descriptor 

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

func (*CryptopanicEntryMetadata) GetDescription 

func (m *CryptopanicEntryMetadata) GetDescription() string

func (*CryptopanicEntryMetadata) GetMessage 

func (m *CryptopanicEntryMetadata) GetMessage() string

func (*CryptopanicEntryMetadata) ProtoMessage 

func (*CryptopanicEntryMetadata) ProtoMessage()

func (*CryptopanicEntryMetadata) Reset 

func (m *CryptopanicEntryMetadata) Reset()

func (*CryptopanicEntryMetadata) String 

func (m *CryptopanicEntryMetadata) String() string

func (*CryptopanicEntryMetadata) XXX_DiscardUnknown 

func (m *CryptopanicEntryMetadata) XXX_DiscardUnknown()

func (*CryptopanicEntryMetadata) XXX_Marshal 

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

func (*CryptopanicEntryMetadata) XXX_Merge 

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

func (*CryptopanicEntryMetadata) XXX_Size 

func (m *CryptopanicEntryMetadata) XXX_Size() int

func (*CryptopanicEntryMetadata) XXX_Unmarshal 

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

type CryptopanicEntrySource 

type CryptopanicEntrySource struct {
	Title                string   `protobuf:"bytes,1,opt,name=title,proto3" json:"title,omitempty"`
	Region               string   `protobuf:"bytes,2,opt,name=region,proto3" json:"region,omitempty"`
	Domain               string   `protobuf:"bytes,3,opt,name=domain,proto3" json:"domain,omitempty"`
	Path                 string   `protobuf:"bytes,4,opt,name=path,proto3" json:"path,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CryptopanicEntrySource) Descriptor 

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

func (*CryptopanicEntrySource) GetDomain 

func (m *CryptopanicEntrySource) GetDomain() string

func (*CryptopanicEntrySource) GetPath 

func (m *CryptopanicEntrySource) GetPath() string

func (*CryptopanicEntrySource) GetRegion 

func (m *CryptopanicEntrySource) GetRegion() string

func (*CryptopanicEntrySource) GetTitle 

func (m *CryptopanicEntrySource) GetTitle() string

func (*CryptopanicEntrySource) ProtoMessage 

func (*CryptopanicEntrySource) ProtoMessage()

func (*CryptopanicEntrySource) Reset 

func (m *CryptopanicEntrySource) Reset()

func (*CryptopanicEntrySource) String 

func (m *CryptopanicEntrySource) String() string

func (*CryptopanicEntrySource) XXX_DiscardUnknown 

func (m *CryptopanicEntrySource) XXX_DiscardUnknown()

func (*CryptopanicEntrySource) XXX_Marshal 

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

func (*CryptopanicEntrySource) XXX_Merge 

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

func (*CryptopanicEntrySource) XXX_Size 

func (m *CryptopanicEntrySource) XXX_Size() int

func (*CryptopanicEntrySource) XXX_Unmarshal 

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

type CryptopanicEntryVotes 

type CryptopanicEntryVotes struct {
	Negative             int32    `protobuf:"varint,1,opt,name=negative,proto3" json:"negative,omitempty"`
	Positive             int32    `protobuf:"varint,2,opt,name=positive,proto3" json:"positive,omitempty"`
	Important            int32    `protobuf:"varint,3,opt,name=important,proto3" json:"important,omitempty"`
	Liked                int32    `protobuf:"varint,4,opt,name=liked,proto3" json:"liked,omitempty"`
	Disliked             int32    `protobuf:"varint,5,opt,name=disliked,proto3" json:"disliked,omitempty"`
	Lol                  int32    `protobuf:"varint,6,opt,name=lol,proto3" json:"lol,omitempty"`
	Toxic                int32    `protobuf:"varint,7,opt,name=toxic,proto3" json:"toxic,omitempty"`
	Saved                int32    `protobuf:"varint,8,opt,name=saved,proto3" json:"saved,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CryptopanicEntryVotes) Descriptor 

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

func (*CryptopanicEntryVotes) GetDisliked 

func (m *CryptopanicEntryVotes) GetDisliked() int32

func (*CryptopanicEntryVotes) GetImportant 

func (m *CryptopanicEntryVotes) GetImportant() int32

func (*CryptopanicEntryVotes) GetLiked 

func (m *CryptopanicEntryVotes) GetLiked() int32

func (*CryptopanicEntryVotes) GetLol 

func (m *CryptopanicEntryVotes) GetLol() int32

func (*CryptopanicEntryVotes) GetNegative 

func (m *CryptopanicEntryVotes) GetNegative() int32

func (*CryptopanicEntryVotes) GetPositive 

func (m *CryptopanicEntryVotes) GetPositive() int32

func (*CryptopanicEntryVotes) GetSaved 

func (m *CryptopanicEntryVotes) GetSaved() int32

func (*CryptopanicEntryVotes) GetToxic 

func (m *CryptopanicEntryVotes) GetToxic() int32

func (*CryptopanicEntryVotes) ProtoMessage 

func (*CryptopanicEntryVotes) ProtoMessage()

func (*CryptopanicEntryVotes) Reset 

func (m *CryptopanicEntryVotes) Reset()

func (*CryptopanicEntryVotes) String 

func (m *CryptopanicEntryVotes) String() string

func (*CryptopanicEntryVotes) XXX_DiscardUnknown 

func (m *CryptopanicEntryVotes) XXX_DiscardUnknown()

func (*CryptopanicEntryVotes) XXX_Marshal 

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

func (*CryptopanicEntryVotes) XXX_Merge 

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

func (*CryptopanicEntryVotes) XXX_Size 

func (m *CryptopanicEntryVotes) XXX_Size() int

func (*CryptopanicEntryVotes) XXX_Unmarshal 

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

type CryptopanicFeed 

type CryptopanicFeed struct {
	Count                int32                  `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	Results              []*CryptopanicRawEntry `protobuf:"bytes,2,rep,name=results,proto3" json:"results,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*CryptopanicFeed) Descriptor 

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

func (*CryptopanicFeed) GetCount 

func (m *CryptopanicFeed) GetCount() int32

func (*CryptopanicFeed) GetResults 

func (m *CryptopanicFeed) GetResults() []*CryptopanicRawEntry

func (*CryptopanicFeed) ProtoMessage 

func (*CryptopanicFeed) ProtoMessage()

func (*CryptopanicFeed) Reset 

func (m *CryptopanicFeed) Reset()

func (*CryptopanicFeed) String 

func (m *CryptopanicFeed) String() string

func (*CryptopanicFeed) XXX_DiscardUnknown 

func (m *CryptopanicFeed) XXX_DiscardUnknown()

func (*CryptopanicFeed) XXX_Marshal 

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

func (*CryptopanicFeed) XXX_Merge 

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

func (*CryptopanicFeed) XXX_Size 

func (m *CryptopanicFeed) XXX_Size() int

func (*CryptopanicFeed) XXX_Unmarshal 

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

type CryptopanicPost 

type CryptopanicPost struct {
	CryptopanicRawEntry  *CryptopanicRawEntry `protobuf:"bytes,1,opt,name=cryptopanic_raw_entry,json=cryptopanicRawEntry,proto3" json:"cryptopanic_raw_entry,omitempty"`
	Article              *Article             `protobuf:"bytes,2,opt,name=article,proto3" json:"article,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*CryptopanicPost) Descriptor 

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

func (*CryptopanicPost) GetArticle 

func (m *CryptopanicPost) GetArticle() *Article

func (*CryptopanicPost) GetCryptopanicRawEntry 

func (m *CryptopanicPost) GetCryptopanicRawEntry() *CryptopanicRawEntry

func (*CryptopanicPost) ProtoMessage 

func (*CryptopanicPost) ProtoMessage()

func (*CryptopanicPost) Reset 

func (m *CryptopanicPost) Reset()

func (*CryptopanicPost) String 

func (m *CryptopanicPost) String() string

func (*CryptopanicPost) XXX_DiscardUnknown 

func (m *CryptopanicPost) XXX_DiscardUnknown()

func (*CryptopanicPost) XXX_Marshal 

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

func (*CryptopanicPost) XXX_Merge 

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

func (*CryptopanicPost) XXX_Size 

func (m *CryptopanicPost) XXX_Size() int

func (*CryptopanicPost) XXX_Unmarshal 

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

type CryptopanicRawEntry 

type CryptopanicRawEntry struct {
	Kind                 string                    `protobuf:"bytes,1,opt,name=kind,proto3" json:"kind,omitempty"`
	Domain               string                    `protobuf:"bytes,2,opt,name=domain,proto3" json:"domain,omitempty"`
	Source               *CryptopanicEntrySource   `protobuf:"bytes,3,opt,name=source,proto3" json:"source,omitempty"`
	Title                string                    `protobuf:"bytes,4,opt,name=title,proto3" json:"title,omitempty"`
	PublishedAt          string                    `protobuf:"bytes,5,opt,name=published_at,json=publishedAt,proto3" json:"published_at,omitempty"`
	Slug                 string                    `protobuf:"bytes,6,opt,name=slug,proto3" json:"slug,omitempty"`
	Id                   int32                     `protobuf:"varint,7,opt,name=id,proto3" json:"id,omitempty"`
	Url                  string                    `protobuf:"bytes,8,opt,name=url,proto3" json:"url,omitempty"`
	CreatedAt            string                    `protobuf:"bytes,9,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	Votes                *CryptopanicEntryVotes    `protobuf:"bytes,10,opt,name=votes,proto3" json:"votes,omitempty"`
	Metadata             *CryptopanicEntryMetadata `protobuf:"bytes,11,opt,name=metadata,proto3" json:"metadata,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*CryptopanicRawEntry) Descriptor 

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

func (*CryptopanicRawEntry) GetCreatedAt 

func (m *CryptopanicRawEntry) GetCreatedAt() string

func (*CryptopanicRawEntry) GetDomain 

func (m *CryptopanicRawEntry) GetDomain() string

func (*CryptopanicRawEntry) GetId 

func (m *CryptopanicRawEntry) GetId() int32

func (*CryptopanicRawEntry) GetKind 

func (m *CryptopanicRawEntry) GetKind() string

func (*CryptopanicRawEntry) GetMetadata 

func (m *CryptopanicRawEntry) GetMetadata() *CryptopanicEntryMetadata

func (*CryptopanicRawEntry) GetPublishedAt 

func (m *CryptopanicRawEntry) GetPublishedAt() string

func (*CryptopanicRawEntry) GetSlug 

func (m *CryptopanicRawEntry) GetSlug() string

func (*CryptopanicRawEntry) GetSource 

func (m *CryptopanicRawEntry) GetSource() *CryptopanicEntrySource

func (*CryptopanicRawEntry) GetTitle 

func (m *CryptopanicRawEntry) GetTitle() string

func (*CryptopanicRawEntry) GetUrl 

func (m *CryptopanicRawEntry) GetUrl() string

func (*CryptopanicRawEntry) GetVotes 

func (m *CryptopanicRawEntry) GetVotes() *CryptopanicEntryVotes

func (*CryptopanicRawEntry) ProtoMessage 

func (*CryptopanicRawEntry) ProtoMessage()

func (*CryptopanicRawEntry) Reset 

func (m *CryptopanicRawEntry) Reset()

func (*CryptopanicRawEntry) String 

func (m *CryptopanicRawEntry) String() string

func (*CryptopanicRawEntry) XXX_DiscardUnknown 

func (m *CryptopanicRawEntry) XXX_DiscardUnknown()

func (*CryptopanicRawEntry) XXX_Marshal 

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

func (*CryptopanicRawEntry) XXX_Merge 

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

func (*CryptopanicRawEntry) XXX_Size 

func (m *CryptopanicRawEntry) XXX_Size() int

func (*CryptopanicRawEntry) XXX_Unmarshal 

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

type DatasetClient 

type DatasetClient interface {
	Assets(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*AssetItems, error)
}

DatasetClient is the client API for Dataset service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewDatasetClient 

func NewDatasetClient(cc grpc.ClientConnInterface) DatasetClient

type DatasetServer 

type DatasetServer interface {
	Assets(context.Context, *empty.Empty) (*AssetItems, error)
}

DatasetServer is the server API for Dataset service.

type HistoricDataClient 

type HistoricDataClient interface {
	HistoricBaseArticles(ctx context.Context, in *HistoricRequest, opts ...grpc.CallOption) (HistoricData_HistoricBaseArticlesClient, error)
	HistoricArticles(ctx context.Context, in *HistoricRequest, opts ...grpc.CallOption) (HistoricData_HistoricArticlesClient, error)
}

HistoricDataClient is the client API for HistoricData service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewHistoricDataClient 

func NewHistoricDataClient(cc grpc.ClientConnInterface) HistoricDataClient

type HistoricDataServer 

type HistoricDataServer interface {
	HistoricBaseArticles(*HistoricRequest, HistoricData_HistoricBaseArticlesServer) error
	HistoricArticles(*HistoricRequest, HistoricData_HistoricArticlesServer) error
}

HistoricDataServer is the server API for HistoricData service.

type HistoricData_HistoricArticlesClient 

type HistoricData_HistoricArticlesClient interface {
	Recv() (*Article, error)
	grpc.ClientStream
}

type HistoricData_HistoricArticlesServer 

type HistoricData_HistoricArticlesServer interface {
	Send(*Article) error
	grpc.ServerStream
}

type HistoricData_HistoricBaseArticlesClient 

type HistoricData_HistoricBaseArticlesClient interface {
	Recv() (*PublicModel, error)
	grpc.ClientStream
}

type HistoricData_HistoricBaseArticlesServer 

type HistoricData_HistoricBaseArticlesServer interface {
	Send(*PublicModel) error
	grpc.ServerStream
}

type HistoricRequest 

type HistoricRequest struct {
	// unix timestamp for start - included in results (greater or equal)
	From *timestamp.Timestamp `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	// unix timestamp for end - excluded from results (
	To                   *timestamp.Timestamp `protobuf:"bytes,2,opt,name=to,proto3" json:"to,omitempty"`
	Filter               *AssetsFilter        `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

* Each request for historic data should be limited by date

func (*HistoricRequest) Descriptor 

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

func (*HistoricRequest) GetFilter 

func (m *HistoricRequest) GetFilter() *AssetsFilter

func (*HistoricRequest) GetFrom 

func (m *HistoricRequest) GetFrom() *timestamp.Timestamp

func (*HistoricRequest) GetTo 

func (m *HistoricRequest) GetTo() *timestamp.Timestamp

func (*HistoricRequest) ProtoMessage 

func (*HistoricRequest) ProtoMessage()

func (*HistoricRequest) Reset 

func (m *HistoricRequest) Reset()

func (*HistoricRequest) String 

func (m *HistoricRequest) String() string

func (*HistoricRequest) XXX_DiscardUnknown 

func (m *HistoricRequest) XXX_DiscardUnknown()

func (*HistoricRequest) XXX_Marshal 

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

func (*HistoricRequest) XXX_Merge 

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

func (*HistoricRequest) XXX_Size 

func (m *HistoricRequest) XXX_Size() int

func (*HistoricRequest) XXX_Unmarshal 

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

type MessagesProxyClient 

type MessagesProxyClient interface {
	SubscribeBaseArticle(ctx context.Context, in *AssetsFilter, opts ...grpc.CallOption) (MessagesProxy_SubscribeBaseArticleClient, error)
	SubscribeArticle(ctx context.Context, in *AssetsFilter, opts ...grpc.CallOption) (MessagesProxy_SubscribeArticleClient, error)
}

MessagesProxyClient is the client API for MessagesProxy service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewMessagesProxyClient 

func NewMessagesProxyClient(cc grpc.ClientConnInterface) MessagesProxyClient

type MessagesProxyServer 

type MessagesProxyServer interface {
	SubscribeBaseArticle(*AssetsFilter, MessagesProxy_SubscribeBaseArticleServer) error
	SubscribeArticle(*AssetsFilter, MessagesProxy_SubscribeArticleServer) error
}

MessagesProxyServer is the server API for MessagesProxy service.

type MessagesProxy_SubscribeArticleClient 

type MessagesProxy_SubscribeArticleClient interface {
	Recv() (*Article, error)
	grpc.ClientStream
}

type MessagesProxy_SubscribeArticleServer 

type MessagesProxy_SubscribeArticleServer interface {
	Send(*Article) error
	grpc.ServerStream
}

type MessagesProxy_SubscribeBaseArticleClient 

type MessagesProxy_SubscribeBaseArticleClient interface {
	Recv() (*PublicModel, error)
	grpc.ClientStream
}

type MessagesProxy_SubscribeBaseArticleServer 

type MessagesProxy_SubscribeBaseArticleServer interface {
	Send(*PublicModel) error
	grpc.ServerStream
}

type NamedEntitiesModel 

type NamedEntitiesModel struct {
	// list of crypto assets
	Symbols []string `protobuf:"bytes,1,rep,name=symbols,proto3" json:"symbols,omitempty"`
	// recognized cryptocurrencies
	Assets []*NamedEntityOccurrence `protobuf:"bytes,2,rep,name=assets,proto3" json:"assets,omitempty"`
	// recognized persons
	Persons []*NamedEntityOccurrence `protobuf:"bytes,3,rep,name=persons,proto3" json:"persons,omitempty"`
	// recognized companies
	Companies []*NamedEntityOccurrence `protobuf:"bytes,4,rep,name=companies,proto3" json:"companies,omitempty"`
	// recognized organizations
	Organizations []*NamedEntityOccurrence `protobuf:"bytes,5,rep,name=organizations,proto3" json:"organizations,omitempty"`
	// recognized locations
	Locations []*NamedEntityOccurrence `protobuf:"bytes,6,rep,name=locations,proto3" json:"locations,omitempty"`
	// recognized exchanges
	Exchanges []*NamedEntityOccurrence `protobuf:"bytes,7,rep,name=exchanges,proto3" json:"exchanges,omitempty"`
	// recognized misc objects
	Misc []*NamedEntityOccurrence `protobuf:"bytes,8,rep,name=misc,proto3" json:"misc,omitempty"`
	// list of assigned tags
	Tags []string `protobuf:"bytes,9,rep,name=tags,proto3" json:"tags,omitempty"`
	// mapped asset to its mention count
	AssetMentions map[string]int32 `` /* 190-byte string literal not displayed */
	// cleaned text which uses NER
	SourceText           string   `protobuf:"bytes,11,opt,name=source_text,json=sourceText,proto3" json:"source_text,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

* Groups all types of named entities we support.

func (*NamedEntitiesModel) Descriptor 

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

func (*NamedEntitiesModel) GetAssetMentions 

func (m *NamedEntitiesModel) GetAssetMentions() map[string]int32

func (*NamedEntitiesModel) GetAssets 

func (m *NamedEntitiesModel) GetAssets() []*NamedEntityOccurrence

func (*NamedEntitiesModel) GetCompanies 

func (m *NamedEntitiesModel) GetCompanies() []*NamedEntityOccurrence

func (*NamedEntitiesModel) GetExchanges 

func (m *NamedEntitiesModel) GetExchanges() []*NamedEntityOccurrence

func (*NamedEntitiesModel) GetLocations 

func (m *NamedEntitiesModel) GetLocations() []*NamedEntityOccurrence

func (*NamedEntitiesModel) GetMisc 

func (m *NamedEntitiesModel) GetMisc() []*NamedEntityOccurrence

func (*NamedEntitiesModel) GetOrganizations 

func (m *NamedEntitiesModel) GetOrganizations() []*NamedEntityOccurrence

func (*NamedEntitiesModel) GetPersons 

func (m *NamedEntitiesModel) GetPersons() []*NamedEntityOccurrence

func (*NamedEntitiesModel) GetSourceText 

func (m *NamedEntitiesModel) GetSourceText() string

func (*NamedEntitiesModel) GetSymbols 

func (m *NamedEntitiesModel) GetSymbols() []string

func (*NamedEntitiesModel) GetTags 

func (m *NamedEntitiesModel) GetTags() []string

func (*NamedEntitiesModel) ProtoMessage 

func (*NamedEntitiesModel) ProtoMessage()

func (*NamedEntitiesModel) Reset 

func (m *NamedEntitiesModel) Reset()

func (*NamedEntitiesModel) String 

func (m *NamedEntitiesModel) String() string

func (*NamedEntitiesModel) XXX_DiscardUnknown 

func (m *NamedEntitiesModel) XXX_DiscardUnknown()

func (*NamedEntitiesModel) XXX_Marshal 

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

func (*NamedEntitiesModel) XXX_Merge 

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

func (*NamedEntitiesModel) XXX_Size 

func (m *NamedEntitiesModel) XXX_Size() int

func (*NamedEntitiesModel) XXX_Unmarshal 

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

type NamedEntity 

type NamedEntity int32

* Types of named entities 

const (
	NamedEntity_ASSET_ENTITY        NamedEntity = 0
	NamedEntity_PERSON_ENTITY       NamedEntity = 1
	NamedEntity_LOCATION_ENTITY     NamedEntity = 2
	NamedEntity_COMPANY_ENTITY      NamedEntity = 3
	NamedEntity_EXCHANGE_ENTITY     NamedEntity = 4
	NamedEntity_MISC_ENTITY         NamedEntity = 5
	NamedEntity_ORGANIZATION_ENTITY NamedEntity = 6
)

func (NamedEntity) EnumDescriptor 

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

func (NamedEntity) String 

func (x NamedEntity) String() string

type NamedEntityOccurrence 

type NamedEntityOccurrence struct {
	// Represents NamedEntity element
	Label NamedEntity `protobuf:"varint,1,opt,name=label,proto3,enum=NamedEntity" json:"label,omitempty"`
	// Start position of occurrence
	Start uint32 `protobuf:"varint,2,opt,name=start,proto3" json:"start,omitempty"`
	// End position of occurrence
	End uint32 `protobuf:"varint,3,opt,name=end,proto3" json:"end,omitempty"`
	// Matched text
	Text                 string   `protobuf:"bytes,4,opt,name=text,proto3" json:"text,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

* Occurrence od named entity. contains position, matched text, category

func (*NamedEntityOccurrence) Descriptor 

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

func (*NamedEntityOccurrence) GetEnd 

func (m *NamedEntityOccurrence) GetEnd() uint32

func (*NamedEntityOccurrence) GetLabel 

func (m *NamedEntityOccurrence) GetLabel() NamedEntity

func (*NamedEntityOccurrence) GetStart 

func (m *NamedEntityOccurrence) GetStart() uint32

func (*NamedEntityOccurrence) GetText 

func (m *NamedEntityOccurrence) GetText() string

func (*NamedEntityOccurrence) ProtoMessage 

func (*NamedEntityOccurrence) ProtoMessage()

func (*NamedEntityOccurrence) Reset 

func (m *NamedEntityOccurrence) Reset()

func (*NamedEntityOccurrence) String 

func (m *NamedEntityOccurrence) String() string

func (*NamedEntityOccurrence) XXX_DiscardUnknown 

func (m *NamedEntityOccurrence) XXX_DiscardUnknown()

func (*NamedEntityOccurrence) XXX_Marshal 

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

func (*NamedEntityOccurrence) XXX_Merge 

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

func (*NamedEntityOccurrence) XXX_Size 

func (m *NamedEntityOccurrence) XXX_Size() int

func (*NamedEntityOccurrence) XXX_Unmarshal 

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

type PublicModel 

type PublicModel struct {
	// unique identifier with schema
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// title of article
	Title string `protobuf:"bytes,2,opt,name=title,proto3" json:"title,omitempty"`
	// full content stripped of unnecessary characters(js, html tags...)
	Content string `protobuf:"bytes,3,opt,name=content,proto3" json:"content,omitempty"`
	// timestamp representing the datetime, when the article has been published
	PubDate *timestamp.Timestamp `protobuf:"bytes,5,opt,name=pub_date,json=pubDate,proto3" json:"pub_date,omitempty"`
	// timestamp representing acquisition datetime
	Created *timestamp.Timestamp `protobuf:"bytes,6,opt,name=created,proto3" json:"created,omitempty"`
	// url of article
	Source string `protobuf:"bytes,7,opt,name=source,proto3" json:"source,omitempty"`
	// summary provided by the domain
	Excerpt string `protobuf:"bytes,8,opt,name=excerpt,proto3" json:"excerpt,omitempty"`
	// list of video sources
	Videos []string `protobuf:"bytes,9,rep,name=videos,proto3" json:"videos,omitempty"`
	// list of image sources
	Images []string `protobuf:"bytes,10,rep,name=images,proto3" json:"images,omitempty"`
	// list of off-page hyperlinks
	Links  []string `protobuf:"bytes,11,rep,name=links,proto3" json:"links,omitempty"`
	Domain string   `protobuf:"bytes,16,opt,name=domain,proto3" json:"domain,omitempty"`
	// additional fields, for now available only 'assets'
	Extensions           *PublicModelExtensions `protobuf:"bytes,100,opt,name=extensions,proto3" json:"extensions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*PublicModel) Descriptor 

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

func (*PublicModel) GetContent 

func (m *PublicModel) GetContent() string

func (*PublicModel) GetCreated 

func (m *PublicModel) GetCreated() *timestamp.Timestamp

func (*PublicModel) GetDomain 

func (m *PublicModel) GetDomain() string

func (*PublicModel) GetExcerpt 

func (m *PublicModel) GetExcerpt() string

func (*PublicModel) GetExtensions 

func (m *PublicModel) GetExtensions() *PublicModelExtensions

func (*PublicModel) GetId 

func (m *PublicModel) GetId() string

func (*PublicModel) GetImages 

func (m *PublicModel) GetImages() []string
func (m *PublicModel) GetLinks() []string

func (*PublicModel) GetPubDate 

func (m *PublicModel) GetPubDate() *timestamp.Timestamp

func (*PublicModel) GetSource 

func (m *PublicModel) GetSource() string

func (*PublicModel) GetTitle 

func (m *PublicModel) GetTitle() string

func (*PublicModel) GetVideos 

func (m *PublicModel) GetVideos() []string

func (*PublicModel) ProtoMessage 

func (*PublicModel) ProtoMessage()

func (*PublicModel) Reset 

func (m *PublicModel) Reset()

func (*PublicModel) String 

func (m *PublicModel) String() string

func (*PublicModel) XXX_DiscardUnknown 

func (m *PublicModel) XXX_DiscardUnknown()

func (*PublicModel) XXX_Marshal 

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

func (*PublicModel) XXX_Merge 

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

func (*PublicModel) XXX_Size 

func (m *PublicModel) XXX_Size() int

func (*PublicModel) XXX_Unmarshal 

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

type PublicModelExtensions 

type PublicModelExtensions struct {
	// assets found in publication
	Assets               []string `protobuf:"bytes,1,rep,name=assets,proto3" json:"assets,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

additional fields to public model

func (*PublicModelExtensions) Descriptor 

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

func (*PublicModelExtensions) GetAssets 

func (m *PublicModelExtensions) GetAssets() []string

func (*PublicModelExtensions) ProtoMessage 

func (*PublicModelExtensions) ProtoMessage()

func (*PublicModelExtensions) Reset 

func (m *PublicModelExtensions) Reset()

func (*PublicModelExtensions) String 

func (m *PublicModelExtensions) String() string

func (*PublicModelExtensions) XXX_DiscardUnknown 

func (m *PublicModelExtensions) XXX_DiscardUnknown()

func (*PublicModelExtensions) XXX_Marshal 

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

func (*PublicModelExtensions) XXX_Merge 

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

func (*PublicModelExtensions) XXX_Size 

func (m *PublicModelExtensions) XXX_Size() int

func (*PublicModelExtensions) XXX_Unmarshal 

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

type SentimentCandle 

type SentimentCandle struct {
	// unique identifier
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// timestamp representing start of the time frame
	StartTime *timestamp.Timestamp `protobuf:"bytes,2,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// constant representing time frame width - M1 or H1
	Resolution string `protobuf:"bytes,3,opt,name=resolution,proto3" json:"resolution,omitempty"`
	// crypto asset
	Asset string `protobuf:"bytes,4,opt,name=asset,proto3" json:"asset,omitempty"`
	// sum of all negative values
	NegativeSum float64 `protobuf:"fixed64,5,opt,name=negative_sum,json=negativeSum,proto3" json:"negative_sum,omitempty"`
	// counted negative occurrences
	NegativeCount int32 `protobuf:"varint,6,opt,name=negative_count,json=negativeCount,proto3" json:"negative_count,omitempty"`
	// sum of all positive values
	PositiveSum float64 `protobuf:"fixed64,7,opt,name=positive_sum,json=positiveSum,proto3" json:"positive_sum,omitempty"`
	// counted positive occurrences
	PositiveCount int32 `protobuf:"varint,8,opt,name=positive_count,json=positiveCount,proto3" json:"positive_count,omitempty"`
	// average of sentiments
	SentimentAvg float64 `protobuf:"fixed64,9,opt,name=sentiment_avg,json=sentimentAvg,proto3" json:"sentiment_avg,omitempty"`
	// value of sentiment at the start of candle
	OpenSentimentAverage float64 `` /* 126-byte string literal not displayed */
	// value of sentiment when the candle is highest
	HighSentimentAverage float64 `` /* 126-byte string literal not displayed */
	// value of sentiment when the candle is lowest
	LowSentimentAverage float64 `protobuf:"fixed64,12,opt,name=low_sentiment_average,json=lowSentimentAverage,proto3" json:"low_sentiment_average,omitempty"`
	// value of sentiment at the end of candle
	CloseSentimentAverage float64 `` /* 129-byte string literal not displayed */
	// flag the signalizes that candle was updated
	Updated              bool     `protobuf:"varint,14,opt,name=updated,proto3" json:"updated,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

* Sentiment message holds informations about aggregated sentiment for specific time window. It is emitted every second for each asset and resolution. If your application needs to receive sentiment updates for only one specific asset, it need to be filtered on your side .

func (*SentimentCandle) Descriptor 

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

func (*SentimentCandle) GetAsset 

func (m *SentimentCandle) GetAsset() string

func (*SentimentCandle) GetCloseSentimentAverage 

func (m *SentimentCandle) GetCloseSentimentAverage() float64

func (*SentimentCandle) GetHighSentimentAverage 

func (m *SentimentCandle) GetHighSentimentAverage() float64

func (*SentimentCandle) GetId 

func (m *SentimentCandle) GetId() string

func (*SentimentCandle) GetLowSentimentAverage 

func (m *SentimentCandle) GetLowSentimentAverage() float64

func (*SentimentCandle) GetNegativeCount 

func (m *SentimentCandle) GetNegativeCount() int32

func (*SentimentCandle) GetNegativeSum 

func (m *SentimentCandle) GetNegativeSum() float64

func (*SentimentCandle) GetOpenSentimentAverage 

func (m *SentimentCandle) GetOpenSentimentAverage() float64

func (*SentimentCandle) GetPositiveCount 

func (m *SentimentCandle) GetPositiveCount() int32

func (*SentimentCandle) GetPositiveSum 

func (m *SentimentCandle) GetPositiveSum() float64

func (*SentimentCandle) GetResolution 

func (m *SentimentCandle) GetResolution() string

func (*SentimentCandle) GetSentimentAvg 

func (m *SentimentCandle) GetSentimentAvg() float64

func (*SentimentCandle) GetStartTime 

func (m *SentimentCandle) GetStartTime() *timestamp.Timestamp

func (*SentimentCandle) GetUpdated 

func (m *SentimentCandle) GetUpdated() bool

func (*SentimentCandle) ProtoMessage 

func (*SentimentCandle) ProtoMessage()

func (*SentimentCandle) Reset 

func (m *SentimentCandle) Reset()

func (*SentimentCandle) String 

func (m *SentimentCandle) String() string

func (*SentimentCandle) XXX_DiscardUnknown 

func (m *SentimentCandle) XXX_DiscardUnknown()

func (*SentimentCandle) XXX_Marshal 

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

func (*SentimentCandle) XXX_Merge 

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

func (*SentimentCandle) XXX_Size 

func (m *SentimentCandle) XXX_Size() int

func (*SentimentCandle) XXX_Unmarshal 

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

type SentimentHistoricRequest 

type SentimentHistoricRequest struct {
	// unix timestamp for start - included in results (greater or equal)
	From *timestamp.Timestamp `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	// unix timestamp for end - excluded from results (
	To *timestamp.Timestamp `protobuf:"bytes,2,opt,name=to,proto3" json:"to,omitempty"`
	// resolution for candle - M1/H1
	Resolution string `protobuf:"bytes,3,opt,name=resolution,proto3" json:"resolution,omitempty"`
	// name of the asset - ie. BTC
	Asset                string   `protobuf:"bytes,4,opt,name=asset,proto3" json:"asset,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

* Each request for historic data should be limited by date

func (*SentimentHistoricRequest) Descriptor 

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

func (*SentimentHistoricRequest) GetAsset 

func (m *SentimentHistoricRequest) GetAsset() string

func (*SentimentHistoricRequest) GetFrom 

func (m *SentimentHistoricRequest) GetFrom() *timestamp.Timestamp

func (*SentimentHistoricRequest) GetResolution 

func (m *SentimentHistoricRequest) GetResolution() string

func (*SentimentHistoricRequest) GetTo 

func (m *SentimentHistoricRequest) GetTo() *timestamp.Timestamp

func (*SentimentHistoricRequest) ProtoMessage 

func (*SentimentHistoricRequest) ProtoMessage()

func (*SentimentHistoricRequest) Reset 

func (m *SentimentHistoricRequest) Reset()

func (*SentimentHistoricRequest) String 

func (m *SentimentHistoricRequest) String() string

func (*SentimentHistoricRequest) XXX_DiscardUnknown 

func (m *SentimentHistoricRequest) XXX_DiscardUnknown()

func (*SentimentHistoricRequest) XXX_Marshal 

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

func (*SentimentHistoricRequest) XXX_Merge 

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

func (*SentimentHistoricRequest) XXX_Size 

func (m *SentimentHistoricRequest) XXX_Size() int

func (*SentimentHistoricRequest) XXX_Unmarshal 

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

type SentimentModel 

type SentimentModel struct {
	// analyzed sentiment <-10, 10>
	Sentiment float64 `protobuf:"fixed64,1,opt,name=sentiment,proto3" json:"sentiment,omitempty"`
	// analyzed impact in the respective area
	MarketImpact float64 `protobuf:"fixed64,2,opt,name=market_impact,json=marketImpact,proto3" json:"market_impact,omitempty"`
	// analyzed replies sentiment <-10, 10>
	SentimentReplies     float64  `protobuf:"fixed64,3,opt,name=sentiment_replies,json=sentimentReplies,proto3" json:"sentiment_replies,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

* Group data that refers to sentiment of message

func (*SentimentModel) Descriptor 

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

func (*SentimentModel) GetMarketImpact 

func (m *SentimentModel) GetMarketImpact() float64

func (*SentimentModel) GetSentiment 

func (m *SentimentModel) GetSentiment() float64

func (*SentimentModel) GetSentimentReplies 

func (m *SentimentModel) GetSentimentReplies() float64

func (*SentimentModel) ProtoMessage 

func (*SentimentModel) ProtoMessage()

func (*SentimentModel) Reset 

func (m *SentimentModel) Reset()

func (*SentimentModel) String 

func (m *SentimentModel) String() string

func (*SentimentModel) XXX_DiscardUnknown 

func (m *SentimentModel) XXX_DiscardUnknown()

func (*SentimentModel) XXX_Marshal 

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

func (*SentimentModel) XXX_Merge 

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

func (*SentimentModel) XXX_Size 

func (m *SentimentModel) XXX_Size() int

func (*SentimentModel) XXX_Unmarshal 

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

type SentimentsClient 

type SentimentsClient interface {
	HistoricSocialSentiment(ctx context.Context, in *SentimentHistoricRequest, opts ...grpc.CallOption) (Sentiments_HistoricSocialSentimentClient, error)
	HistoricNewsSentiment(ctx context.Context, in *SentimentHistoricRequest, opts ...grpc.CallOption) (Sentiments_HistoricNewsSentimentClient, error)
	SubscribeSocialSentiment(ctx context.Context, in *AggregationCandleFilter, opts ...grpc.CallOption) (Sentiments_SubscribeSocialSentimentClient, error)
	SubscribeNewsSentiment(ctx context.Context, in *AggregationCandleFilter, opts ...grpc.CallOption) (Sentiments_SubscribeNewsSentimentClient, error)
}

SentimentsClient is the client API for Sentiments service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewSentimentsClient 

func NewSentimentsClient(cc grpc.ClientConnInterface) SentimentsClient

type SentimentsServer 

type SentimentsServer interface {
	HistoricSocialSentiment(*SentimentHistoricRequest, Sentiments_HistoricSocialSentimentServer) error
	HistoricNewsSentiment(*SentimentHistoricRequest, Sentiments_HistoricNewsSentimentServer) error
	SubscribeSocialSentiment(*AggregationCandleFilter, Sentiments_SubscribeSocialSentimentServer) error
	SubscribeNewsSentiment(*AggregationCandleFilter, Sentiments_SubscribeNewsSentimentServer) error
}

SentimentsServer is the server API for Sentiments service.

type Sentiments_HistoricNewsSentimentClient 

type Sentiments_HistoricNewsSentimentClient interface {
	Recv() (*AggregationCandle, error)
	grpc.ClientStream
}

type Sentiments_HistoricNewsSentimentServer 

type Sentiments_HistoricNewsSentimentServer interface {
	Send(*AggregationCandle) error
	grpc.ServerStream
}

type Sentiments_HistoricSocialSentimentClient 

type Sentiments_HistoricSocialSentimentClient interface {
	Recv() (*AggregationCandle, error)
	grpc.ClientStream
}

type Sentiments_HistoricSocialSentimentServer 

type Sentiments_HistoricSocialSentimentServer interface {
	Send(*AggregationCandle) error
	grpc.ServerStream
}

type Sentiments_SubscribeNewsSentimentClient 

type Sentiments_SubscribeNewsSentimentClient interface {
	Recv() (*AggregationCandle, error)
	grpc.ClientStream
}

type Sentiments_SubscribeNewsSentimentServer 

type Sentiments_SubscribeNewsSentimentServer interface {
	Send(*AggregationCandle) error
	grpc.ServerStream
}

type Sentiments_SubscribeSocialSentimentClient 

type Sentiments_SubscribeSocialSentimentClient interface {
	Recv() (*AggregationCandle, error)
	grpc.ClientStream
}

type Sentiments_SubscribeSocialSentimentServer 

type Sentiments_SubscribeSocialSentimentServer interface {
	Send(*AggregationCandle) error
	grpc.ServerStream
}

type Transaction 

type Transaction struct {
	Id                   string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Hash                 string               `protobuf:"bytes,2,opt,name=hash,proto3" json:"hash,omitempty"`
	FromAddress          string               `protobuf:"bytes,3,opt,name=from_address,json=fromAddress,proto3" json:"from_address,omitempty"`
	ToAddress            string               `protobuf:"bytes,4,opt,name=to_address,json=toAddress,proto3" json:"to_address,omitempty"`
	FromOwner            string               `protobuf:"bytes,5,opt,name=from_owner,json=fromOwner,proto3" json:"from_owner,omitempty"`
	ToOwner              string               `protobuf:"bytes,6,opt,name=to_owner,json=toOwner,proto3" json:"to_owner,omitempty"`
	Time                 *timestamp.Timestamp `protobuf:"bytes,7,opt,name=time,proto3" json:"time,omitempty"`
	Comment              string               `protobuf:"bytes,8,opt,name=comment,proto3" json:"comment,omitempty"`
	Asset                string               `protobuf:"bytes,9,opt,name=asset,proto3" json:"asset,omitempty"`
	Size                 float64              `protobuf:"fixed64,10,opt,name=size,proto3" json:"size,omitempty"`
	USDSize              float64              `protobuf:"fixed64,11,opt,name=USD_size,json=USDSize,proto3" json:"USD_size,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*Transaction) Descriptor 

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

func (*Transaction) GetAsset 

func (m *Transaction) GetAsset() string

func (*Transaction) GetComment 

func (m *Transaction) GetComment() string

func (*Transaction) GetFromAddress 

func (m *Transaction) GetFromAddress() string

func (*Transaction) GetFromOwner 

func (m *Transaction) GetFromOwner() string

func (*Transaction) GetHash 

func (m *Transaction) GetHash() string

func (*Transaction) GetId 

func (m *Transaction) GetId() string

func (*Transaction) GetSize 

func (m *Transaction) GetSize() float64

func (*Transaction) GetTime 

func (m *Transaction) GetTime() *timestamp.Timestamp

func (*Transaction) GetToAddress 

func (m *Transaction) GetToAddress() string

func (*Transaction) GetToOwner 

func (m *Transaction) GetToOwner() string

func (*Transaction) GetUSDSize 

func (m *Transaction) GetUSDSize() float64

func (*Transaction) ProtoMessage 

func (*Transaction) ProtoMessage()

func (*Transaction) Reset 

func (m *Transaction) Reset()

func (*Transaction) String 

func (m *Transaction) String() string

func (*Transaction) XXX_DiscardUnknown 

func (m *Transaction) XXX_DiscardUnknown()

func (*Transaction) XXX_Marshal 

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

func (*Transaction) XXX_Merge 

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

func (*Transaction) XXX_Size 

func (m *Transaction) XXX_Size() int

func (*Transaction) XXX_Unmarshal 

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

type UnimplementedDatasetServer 

type UnimplementedDatasetServer struct {
}

UnimplementedDatasetServer can be embedded to have forward compatible implementations.

func (*UnimplementedDatasetServer) Assets 

func (*UnimplementedDatasetServer) Assets(ctx context.Context, req *empty.Empty) (*AssetItems, error)

type UnimplementedHistoricDataServer 

type UnimplementedHistoricDataServer struct {
}

UnimplementedHistoricDataServer can be embedded to have forward compatible implementations.

func (*UnimplementedHistoricDataServer) HistoricArticles 

func (*UnimplementedHistoricDataServer) HistoricArticles(req *HistoricRequest, srv HistoricData_HistoricArticlesServer) error

func (*UnimplementedHistoricDataServer) HistoricBaseArticles 

func (*UnimplementedHistoricDataServer) HistoricBaseArticles(req *HistoricRequest, srv HistoricData_HistoricBaseArticlesServer) error

type UnimplementedMessagesProxyServer 

type UnimplementedMessagesProxyServer struct {
}

UnimplementedMessagesProxyServer can be embedded to have forward compatible implementations.

func (*UnimplementedMessagesProxyServer) SubscribeArticle 

func (*UnimplementedMessagesProxyServer) SubscribeArticle(req *AssetsFilter, srv MessagesProxy_SubscribeArticleServer) error

func (*UnimplementedMessagesProxyServer) SubscribeBaseArticle 

func (*UnimplementedMessagesProxyServer) SubscribeBaseArticle(req *AssetsFilter, srv MessagesProxy_SubscribeBaseArticleServer) error

type UnimplementedSentimentsServer 

type UnimplementedSentimentsServer struct {
}

UnimplementedSentimentsServer can be embedded to have forward compatible implementations.

func (*UnimplementedSentimentsServer) HistoricNewsSentiment 

func (*UnimplementedSentimentsServer) HistoricNewsSentiment(req *SentimentHistoricRequest, srv Sentiments_HistoricNewsSentimentServer) error

func (*UnimplementedSentimentsServer) HistoricSocialSentiment 

func (*UnimplementedSentimentsServer) HistoricSocialSentiment(req *SentimentHistoricRequest, srv Sentiments_HistoricSocialSentimentServer) error

func (*UnimplementedSentimentsServer) SubscribeNewsSentiment 

func (*UnimplementedSentimentsServer) SubscribeNewsSentiment(req *AggregationCandleFilter, srv Sentiments_SubscribeNewsSentimentServer) error

func (*UnimplementedSentimentsServer) SubscribeSocialSentiment 

func (*UnimplementedSentimentsServer) SubscribeSocialSentiment(req *AggregationCandleFilter, srv Sentiments_SubscribeSocialSentimentServer) error

type UserMessage 

type UserMessage struct {
	Base          *BaseModel          `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	Sentiment     *SentimentModel     `protobuf:"bytes,2,opt,name=sentiment,proto3" json:"sentiment,omitempty"`
	NamedEntities *NamedEntitiesModel `protobuf:"bytes,3,opt,name=named_entities,json=namedEntities,proto3" json:"named_entities,omitempty"`
	// nickname of user
	User string `protobuf:"bytes,4,opt,name=user,proto3" json:"user,omitempty"`
	// text of message
	Message              string   `protobuf:"bytes,5,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

* Basic model for media where the messages are wrote by regular user

func (*UserMessage) Descriptor 

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

func (*UserMessage) GetBase 

func (m *UserMessage) GetBase() *BaseModel

func (*UserMessage) GetMessage 

func (m *UserMessage) GetMessage() string

func (*UserMessage) GetNamedEntities 

func (m *UserMessage) GetNamedEntities() *NamedEntitiesModel

func (*UserMessage) GetSentiment 

func (m *UserMessage) GetSentiment() *SentimentModel

func (*UserMessage) GetUser 

func (m *UserMessage) GetUser() string

func (*UserMessage) ProtoMessage 

func (*UserMessage) ProtoMessage()

func (*UserMessage) Reset 

func (m *UserMessage) Reset()

func (*UserMessage) String 

func (m *UserMessage) String() string

func (*UserMessage) XXX_DiscardUnknown 

func (m *UserMessage) XXX_DiscardUnknown()

func (*UserMessage) XXX_Marshal 

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

func (*UserMessage) XXX_Merge 

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

func (*UserMessage) XXX_Size 

func (m *UserMessage) XXX_Size() int

func (*UserMessage) XXX_Unmarshal 

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

Source Files

View all Source files

Directories

Path Synopsis
Dataset
Assets
HistoricData
HistoricArticles
HistoricBaseArticles
MessagesProxy
SubscribeArticle
SubscribeBaseArticle
Sentiments
HistoricNewsSentiment
HistoricSocialSentiment
SubscribeNewsSentiment
SubscribeSocialSentiment

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.