amqp

package module
v0.0.2 Latest Latest
Warning

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

Go to latest
Published: May 5, 2023 License: GPL-3.0 Imports: 10 Imported by: 55

README

This project uses the protoc command to generate Go files from proto files.

  • To install the protobuf compiler:
apt install protobuf-compiler
go install google.golang.org/protobuf/cmd/protoc-gen-go@latest
  • To generate new go file based on proto source:
protoc --go_out=. rabbitmq.proto

Documentation

Index

Constants

View Source
const (
	ContextCorrelationID ContextKey = "correlationID"

	ExchangeRequest Exchange = "requests"
	ExchangeAnswer  Exchange = "answers"
	ExchangeNews    Exchange = "news"
)

Variables

View Source
var (
	Language_name = map[int32]string{
		0: "ANY",
		1: "FR",
		2: "EN",
		3: "ES",
	}
	Language_value = map[string]int32{
		"ANY": 0,
		"FR":  1,
		"EN":  2,
		"ES":  3,
	}
)

Enum value maps for Language.

View Source
var (
	RabbitMQMessage_Type_name = map[int32]string{
		0:   "UNKNOWN",
		100: "NEWS_RSS",
		101: "NEWS_TWITTER",
		200: "PORTAL_POSITION_REQUEST",
		201: "PORTAL_POSITION_ANSWER",
		300: "CONFIGURATION_GET_REQUEST",
		301: "CONFIGURATION_GET_ANSWER",
		302: "CONFIGURATION_SET_SERVER_REQUEST",
		303: "CONFIGURATION_SET_ALMANAX_WEBHOOK_REQUEST",
		304: "CONFIGURATION_SET_RSS_WEBHOOK_REQUEST",
		305: "CONFIGURATION_SET_TWITTER_WEBHOOK_REQUEST",
		306: "CONFIGURATION_SET_ANSWER",
		400: "JOB_GET_BOOK_REQUEST",
		401: "JOB_GET_BOOK_ANSWER",
		402: "JOB_GET_USER_REQUEST",
		403: "JOB_GET_USER_ANSWER",
		404: "JOB_SET_REQUEST",
		405: "JOB_SET_ANSWER",
		500: "ALIGN_GET_BOOK_REQUEST",
		501: "ALIGN_GET_BOOK_ANSWER",
		502: "ALIGN_GET_USER_REQUEST",
		503: "ALIGN_GET_USER_ANSWER",
		504: "ALIGN_SET_REQUEST",
		505: "ALIGN_SET_ANSWER",
	}
	RabbitMQMessage_Type_value = map[string]int32{
		"UNKNOWN":                                   0,
		"NEWS_RSS":                                  100,
		"NEWS_TWITTER":                              101,
		"PORTAL_POSITION_REQUEST":                   200,
		"PORTAL_POSITION_ANSWER":                    201,
		"CONFIGURATION_GET_REQUEST":                 300,
		"CONFIGURATION_GET_ANSWER":                  301,
		"CONFIGURATION_SET_SERVER_REQUEST":          302,
		"CONFIGURATION_SET_ALMANAX_WEBHOOK_REQUEST": 303,
		"CONFIGURATION_SET_RSS_WEBHOOK_REQUEST":     304,
		"CONFIGURATION_SET_TWITTER_WEBHOOK_REQUEST": 305,
		"CONFIGURATION_SET_ANSWER":                  306,
		"JOB_GET_BOOK_REQUEST":                      400,
		"JOB_GET_BOOK_ANSWER":                       401,
		"JOB_GET_USER_REQUEST":                      402,
		"JOB_GET_USER_ANSWER":                       403,
		"JOB_SET_REQUEST":                           404,
		"JOB_SET_ANSWER":                            405,
		"ALIGN_GET_BOOK_REQUEST":                    500,
		"ALIGN_GET_BOOK_ANSWER":                     501,
		"ALIGN_GET_USER_REQUEST":                    502,
		"ALIGN_GET_USER_ANSWER":                     503,
		"ALIGN_SET_REQUEST":                         504,
		"ALIGN_SET_ANSWER":                          505,
	}
)

Enum value maps for RabbitMQMessage_Type.

View Source
var (
	RabbitMQMessage_Status_name = map[int32]string{
		0: "SUCCESS",
		1: "FAILED",
	}
	RabbitMQMessage_Status_value = map[string]int32{
		"SUCCESS": 0,
		"FAILED":  1,
	}
)

Enum value maps for RabbitMQMessage_Status.

View Source
var (
	ErrCannotBeConnected = errors.New("cannot be connected, please check AMQP server or address")
	ErrMustBeConnected   = errors.New("this function requires to be connected to AMQP server")
)
View Source
var File_rabbitmq_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type AlignGetBookAnswer added in v0.0.2

type AlignGetBookAnswer struct {
	ServerId  string                         `protobuf:"bytes,1,opt,name=serverId,proto3" json:"serverId,omitempty"`
	Believers []*AlignGetBookAnswer_Believer `protobuf:"bytes,2,rep,name=believers,proto3" json:"believers,omitempty"`
	// contains filtered or unexported fields
}

func (*AlignGetBookAnswer) Descriptor deprecated added in v0.0.2

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

Deprecated: Use AlignGetBookAnswer.ProtoReflect.Descriptor instead.

func (*AlignGetBookAnswer) GetBelievers added in v0.0.2

func (x *AlignGetBookAnswer) GetBelievers() []*AlignGetBookAnswer_Believer

func (*AlignGetBookAnswer) GetServerId added in v0.0.2

func (x *AlignGetBookAnswer) GetServerId() string

func (*AlignGetBookAnswer) ProtoMessage added in v0.0.2

func (*AlignGetBookAnswer) ProtoMessage()

func (*AlignGetBookAnswer) ProtoReflect added in v0.0.2

func (x *AlignGetBookAnswer) ProtoReflect() protoreflect.Message

func (*AlignGetBookAnswer) Reset added in v0.0.2

func (x *AlignGetBookAnswer) Reset()

func (*AlignGetBookAnswer) String added in v0.0.2

func (x *AlignGetBookAnswer) String() string

type AlignGetBookAnswer_Believer added in v0.0.2

type AlignGetBookAnswer_Believer struct {
	CityId  string `protobuf:"bytes,1,opt,name=cityId,proto3" json:"cityId,omitempty"`
	OrderId string `protobuf:"bytes,2,opt,name=orderId,proto3" json:"orderId,omitempty"`
	UserId  string `protobuf:"bytes,3,opt,name=userId,proto3" json:"userId,omitempty"`
	Level   int64  `protobuf:"varint,4,opt,name=level,proto3" json:"level,omitempty"`
	// contains filtered or unexported fields
}

func (*AlignGetBookAnswer_Believer) Descriptor deprecated added in v0.0.2

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

Deprecated: Use AlignGetBookAnswer_Believer.ProtoReflect.Descriptor instead.

func (*AlignGetBookAnswer_Believer) GetCityId added in v0.0.2

func (x *AlignGetBookAnswer_Believer) GetCityId() string

func (*AlignGetBookAnswer_Believer) GetLevel added in v0.0.2

func (x *AlignGetBookAnswer_Believer) GetLevel() int64

func (*AlignGetBookAnswer_Believer) GetOrderId added in v0.0.2

func (x *AlignGetBookAnswer_Believer) GetOrderId() string

func (*AlignGetBookAnswer_Believer) GetUserId added in v0.0.2

func (x *AlignGetBookAnswer_Believer) GetUserId() string

func (*AlignGetBookAnswer_Believer) ProtoMessage added in v0.0.2

func (*AlignGetBookAnswer_Believer) ProtoMessage()

func (*AlignGetBookAnswer_Believer) ProtoReflect added in v0.0.2

func (*AlignGetBookAnswer_Believer) Reset added in v0.0.2

func (x *AlignGetBookAnswer_Believer) Reset()

func (*AlignGetBookAnswer_Believer) String added in v0.0.2

func (x *AlignGetBookAnswer_Believer) String() string

type AlignGetBookRequest added in v0.0.2

type AlignGetBookRequest struct {
	UserIds  []string `protobuf:"bytes,1,rep,name=userIds,proto3" json:"userIds,omitempty"`
	CityId   string   `protobuf:"bytes,2,opt,name=cityId,proto3" json:"cityId,omitempty"`
	OrderId  string   `protobuf:"bytes,3,opt,name=orderId,proto3" json:"orderId,omitempty"`
	ServerId string   `protobuf:"bytes,4,opt,name=serverId,proto3" json:"serverId,omitempty"`
	Limit    int64    `protobuf:"varint,5,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*AlignGetBookRequest) Descriptor deprecated added in v0.0.2

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

Deprecated: Use AlignGetBookRequest.ProtoReflect.Descriptor instead.

func (*AlignGetBookRequest) GetCityId added in v0.0.2

func (x *AlignGetBookRequest) GetCityId() string

func (*AlignGetBookRequest) GetLimit added in v0.0.2

func (x *AlignGetBookRequest) GetLimit() int64

func (*AlignGetBookRequest) GetOrderId added in v0.0.2

func (x *AlignGetBookRequest) GetOrderId() string

func (*AlignGetBookRequest) GetServerId added in v0.0.2

func (x *AlignGetBookRequest) GetServerId() string

func (*AlignGetBookRequest) GetUserIds added in v0.0.2

func (x *AlignGetBookRequest) GetUserIds() []string

func (*AlignGetBookRequest) ProtoMessage added in v0.0.2

func (*AlignGetBookRequest) ProtoMessage()

func (*AlignGetBookRequest) ProtoReflect added in v0.0.2

func (x *AlignGetBookRequest) ProtoReflect() protoreflect.Message

func (*AlignGetBookRequest) Reset added in v0.0.2

func (x *AlignGetBookRequest) Reset()

func (*AlignGetBookRequest) String added in v0.0.2

func (x *AlignGetBookRequest) String() string

type AlignGetUserAnswer added in v0.0.2

type AlignGetUserAnswer struct {
	ServerId string                                `protobuf:"bytes,1,opt,name=serverId,proto3" json:"serverId,omitempty"`
	Beliefs  []*AlignGetUserAnswer_AlignExperience `protobuf:"bytes,2,rep,name=beliefs,proto3" json:"beliefs,omitempty"`
	// contains filtered or unexported fields
}

func (*AlignGetUserAnswer) Descriptor deprecated added in v0.0.2

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

Deprecated: Use AlignGetUserAnswer.ProtoReflect.Descriptor instead.

func (*AlignGetUserAnswer) GetBeliefs added in v0.0.2

func (*AlignGetUserAnswer) GetServerId added in v0.0.2

func (x *AlignGetUserAnswer) GetServerId() string

func (*AlignGetUserAnswer) ProtoMessage added in v0.0.2

func (*AlignGetUserAnswer) ProtoMessage()

func (*AlignGetUserAnswer) ProtoReflect added in v0.0.2

func (x *AlignGetUserAnswer) ProtoReflect() protoreflect.Message

func (*AlignGetUserAnswer) Reset added in v0.0.2

func (x *AlignGetUserAnswer) Reset()

func (*AlignGetUserAnswer) String added in v0.0.2

func (x *AlignGetUserAnswer) String() string

type AlignGetUserAnswer_AlignExperience added in v0.0.2

type AlignGetUserAnswer_AlignExperience struct {
	CityId  string `protobuf:"bytes,1,opt,name=cityId,proto3" json:"cityId,omitempty"`
	OrderId string `protobuf:"bytes,2,opt,name=orderId,proto3" json:"orderId,omitempty"`
	Level   int64  `protobuf:"varint,3,opt,name=level,proto3" json:"level,omitempty"`
	// contains filtered or unexported fields
}

func (*AlignGetUserAnswer_AlignExperience) Descriptor deprecated added in v0.0.2

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

Deprecated: Use AlignGetUserAnswer_AlignExperience.ProtoReflect.Descriptor instead.

func (*AlignGetUserAnswer_AlignExperience) GetCityId added in v0.0.2

func (*AlignGetUserAnswer_AlignExperience) GetLevel added in v0.0.2

func (*AlignGetUserAnswer_AlignExperience) GetOrderId added in v0.0.2

func (*AlignGetUserAnswer_AlignExperience) ProtoMessage added in v0.0.2

func (*AlignGetUserAnswer_AlignExperience) ProtoMessage()

func (*AlignGetUserAnswer_AlignExperience) ProtoReflect added in v0.0.2

func (*AlignGetUserAnswer_AlignExperience) Reset added in v0.0.2

func (*AlignGetUserAnswer_AlignExperience) String added in v0.0.2

type AlignGetUserRequest added in v0.0.2

type AlignGetUserRequest struct {
	UserId   string `protobuf:"bytes,1,opt,name=userId,proto3" json:"userId,omitempty"`
	ServerId string `protobuf:"bytes,2,opt,name=serverId,proto3" json:"serverId,omitempty"`
	// contains filtered or unexported fields
}

func (*AlignGetUserRequest) Descriptor deprecated added in v0.0.2

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

Deprecated: Use AlignGetUserRequest.ProtoReflect.Descriptor instead.

func (*AlignGetUserRequest) GetServerId added in v0.0.2

func (x *AlignGetUserRequest) GetServerId() string

func (*AlignGetUserRequest) GetUserId added in v0.0.2

func (x *AlignGetUserRequest) GetUserId() string

func (*AlignGetUserRequest) ProtoMessage added in v0.0.2

func (*AlignGetUserRequest) ProtoMessage()

func (*AlignGetUserRequest) ProtoReflect added in v0.0.2

func (x *AlignGetUserRequest) ProtoReflect() protoreflect.Message

func (*AlignGetUserRequest) Reset added in v0.0.2

func (x *AlignGetUserRequest) Reset()

func (*AlignGetUserRequest) String added in v0.0.2

func (x *AlignGetUserRequest) String() string

type AlignSetAnswer added in v0.0.2

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

func (*AlignSetAnswer) Descriptor deprecated added in v0.0.2

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

Deprecated: Use AlignSetAnswer.ProtoReflect.Descriptor instead.

func (*AlignSetAnswer) ProtoMessage added in v0.0.2

func (*AlignSetAnswer) ProtoMessage()

func (*AlignSetAnswer) ProtoReflect added in v0.0.2

func (x *AlignSetAnswer) ProtoReflect() protoreflect.Message

func (*AlignSetAnswer) Reset added in v0.0.2

func (x *AlignSetAnswer) Reset()

func (*AlignSetAnswer) String added in v0.0.2

func (x *AlignSetAnswer) String() string

type AlignSetRequest added in v0.0.2

type AlignSetRequest struct {
	UserId   string `protobuf:"bytes,1,opt,name=userId,proto3" json:"userId,omitempty"`
	CityId   string `protobuf:"bytes,2,opt,name=cityId,proto3" json:"cityId,omitempty"`
	OrderId  string `protobuf:"bytes,3,opt,name=orderId,proto3" json:"orderId,omitempty"`
	ServerId string `protobuf:"bytes,4,opt,name=serverId,proto3" json:"serverId,omitempty"`
	Level    int64  `protobuf:"varint,5,opt,name=level,proto3" json:"level,omitempty"`
	// contains filtered or unexported fields
}

func (*AlignSetRequest) Descriptor deprecated added in v0.0.2

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

Deprecated: Use AlignSetRequest.ProtoReflect.Descriptor instead.

func (*AlignSetRequest) GetCityId added in v0.0.2

func (x *AlignSetRequest) GetCityId() string

func (*AlignSetRequest) GetLevel added in v0.0.2

func (x *AlignSetRequest) GetLevel() int64

func (*AlignSetRequest) GetOrderId added in v0.0.2

func (x *AlignSetRequest) GetOrderId() string

func (*AlignSetRequest) GetServerId added in v0.0.2

func (x *AlignSetRequest) GetServerId() string

func (*AlignSetRequest) GetUserId added in v0.0.2

func (x *AlignSetRequest) GetUserId() string

func (*AlignSetRequest) ProtoMessage added in v0.0.2

func (*AlignSetRequest) ProtoMessage()

func (*AlignSetRequest) ProtoReflect added in v0.0.2

func (x *AlignSetRequest) ProtoReflect() protoreflect.Message

func (*AlignSetRequest) Reset added in v0.0.2

func (x *AlignSetRequest) Reset()

func (*AlignSetRequest) String added in v0.0.2

func (x *AlignSetRequest) String() string

type Binding

type Binding struct {
	Exchange   Exchange
	RoutingKey string
	Queue      string
}

type ConfigurationGetAnswer added in v0.0.2

type ConfigurationGetAnswer struct {
	GuildId         string                                   `protobuf:"bytes,1,opt,name=guildId,proto3" json:"guildId,omitempty"`
	ServerId        string                                   `protobuf:"bytes,2,opt,name=serverId,proto3" json:"serverId,omitempty"`
	ChannelServers  []*ConfigurationGetAnswer_ChannelServer  `protobuf:"bytes,3,rep,name=channelServers,proto3" json:"channelServers,omitempty"`
	AlmanaxWebhooks []*ConfigurationGetAnswer_AlmanaxWebhook `protobuf:"bytes,4,rep,name=almanaxWebhooks,proto3" json:"almanaxWebhooks,omitempty"`
	RssWebhooks     []*ConfigurationGetAnswer_RssWebhook     `protobuf:"bytes,5,rep,name=rssWebhooks,proto3" json:"rssWebhooks,omitempty"`
	TwitterWebhooks []*ConfigurationGetAnswer_TwitterWebhook `protobuf:"bytes,6,rep,name=twitterWebhooks,proto3" json:"twitterWebhooks,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigurationGetAnswer) Descriptor deprecated added in v0.0.2

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

Deprecated: Use ConfigurationGetAnswer.ProtoReflect.Descriptor instead.

func (*ConfigurationGetAnswer) GetAlmanaxWebhooks added in v0.0.2

func (*ConfigurationGetAnswer) GetChannelServers added in v0.0.2

func (*ConfigurationGetAnswer) GetGuildId added in v0.0.2

func (x *ConfigurationGetAnswer) GetGuildId() string

func (*ConfigurationGetAnswer) GetRssWebhooks added in v0.0.2

func (*ConfigurationGetAnswer) GetServerId added in v0.0.2

func (x *ConfigurationGetAnswer) GetServerId() string

func (*ConfigurationGetAnswer) GetTwitterWebhooks added in v0.0.2

func (*ConfigurationGetAnswer) ProtoMessage added in v0.0.2

func (*ConfigurationGetAnswer) ProtoMessage()

func (*ConfigurationGetAnswer) ProtoReflect added in v0.0.2

func (x *ConfigurationGetAnswer) ProtoReflect() protoreflect.Message

func (*ConfigurationGetAnswer) Reset added in v0.0.2

func (x *ConfigurationGetAnswer) Reset()

func (*ConfigurationGetAnswer) String added in v0.0.2

func (x *ConfigurationGetAnswer) String() string

type ConfigurationGetAnswer_AlmanaxWebhook added in v0.0.2

type ConfigurationGetAnswer_AlmanaxWebhook struct {
	ChannelId string   `protobuf:"bytes,1,opt,name=channelId,proto3" json:"channelId,omitempty"`
	WebhookId string   `protobuf:"bytes,2,opt,name=webhookId,proto3" json:"webhookId,omitempty"`
	Language  Language `protobuf:"varint,3,opt,name=language,proto3,enum=amqp.Language" json:"language,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigurationGetAnswer_AlmanaxWebhook) Descriptor deprecated added in v0.0.2

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

Deprecated: Use ConfigurationGetAnswer_AlmanaxWebhook.ProtoReflect.Descriptor instead.

func (*ConfigurationGetAnswer_AlmanaxWebhook) GetChannelId added in v0.0.2

func (*ConfigurationGetAnswer_AlmanaxWebhook) GetLanguage added in v0.0.2

func (*ConfigurationGetAnswer_AlmanaxWebhook) GetWebhookId added in v0.0.2

func (*ConfigurationGetAnswer_AlmanaxWebhook) ProtoMessage added in v0.0.2

func (*ConfigurationGetAnswer_AlmanaxWebhook) ProtoMessage()

func (*ConfigurationGetAnswer_AlmanaxWebhook) ProtoReflect added in v0.0.2

func (*ConfigurationGetAnswer_AlmanaxWebhook) Reset added in v0.0.2

func (*ConfigurationGetAnswer_AlmanaxWebhook) String added in v0.0.2

type ConfigurationGetAnswer_ChannelServer added in v0.0.2

type ConfigurationGetAnswer_ChannelServer struct {
	ChannelId string `protobuf:"bytes,1,opt,name=channelId,proto3" json:"channelId,omitempty"`
	ServerId  string `protobuf:"bytes,2,opt,name=serverId,proto3" json:"serverId,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigurationGetAnswer_ChannelServer) Descriptor deprecated added in v0.0.2

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

Deprecated: Use ConfigurationGetAnswer_ChannelServer.ProtoReflect.Descriptor instead.

func (*ConfigurationGetAnswer_ChannelServer) GetChannelId added in v0.0.2

func (x *ConfigurationGetAnswer_ChannelServer) GetChannelId() string

func (*ConfigurationGetAnswer_ChannelServer) GetServerId added in v0.0.2

func (*ConfigurationGetAnswer_ChannelServer) ProtoMessage added in v0.0.2

func (*ConfigurationGetAnswer_ChannelServer) ProtoMessage()

func (*ConfigurationGetAnswer_ChannelServer) ProtoReflect added in v0.0.2

func (*ConfigurationGetAnswer_ChannelServer) Reset added in v0.0.2

func (*ConfigurationGetAnswer_ChannelServer) String added in v0.0.2

type ConfigurationGetAnswer_RssWebhook added in v0.0.2

type ConfigurationGetAnswer_RssWebhook struct {
	ChannelId string   `protobuf:"bytes,1,opt,name=channelId,proto3" json:"channelId,omitempty"`
	FeedId    string   `protobuf:"bytes,2,opt,name=feedId,proto3" json:"feedId,omitempty"`
	WebhookId string   `protobuf:"bytes,3,opt,name=webhookId,proto3" json:"webhookId,omitempty"`
	Language  Language `protobuf:"varint,4,opt,name=language,proto3,enum=amqp.Language" json:"language,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigurationGetAnswer_RssWebhook) Descriptor deprecated added in v0.0.2

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

Deprecated: Use ConfigurationGetAnswer_RssWebhook.ProtoReflect.Descriptor instead.

func (*ConfigurationGetAnswer_RssWebhook) GetChannelId added in v0.0.2

func (x *ConfigurationGetAnswer_RssWebhook) GetChannelId() string

func (*ConfigurationGetAnswer_RssWebhook) GetFeedId added in v0.0.2

func (*ConfigurationGetAnswer_RssWebhook) GetLanguage added in v0.0.2

func (*ConfigurationGetAnswer_RssWebhook) GetWebhookId added in v0.0.2

func (x *ConfigurationGetAnswer_RssWebhook) GetWebhookId() string

func (*ConfigurationGetAnswer_RssWebhook) ProtoMessage added in v0.0.2

func (*ConfigurationGetAnswer_RssWebhook) ProtoMessage()

func (*ConfigurationGetAnswer_RssWebhook) ProtoReflect added in v0.0.2

func (*ConfigurationGetAnswer_RssWebhook) Reset added in v0.0.2

func (*ConfigurationGetAnswer_RssWebhook) String added in v0.0.2

type ConfigurationGetAnswer_TwitterWebhook added in v0.0.2

type ConfigurationGetAnswer_TwitterWebhook struct {
	ChannelId string   `protobuf:"bytes,1,opt,name=channelId,proto3" json:"channelId,omitempty"`
	Name      string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	WebhookId string   `protobuf:"bytes,3,opt,name=webhookId,proto3" json:"webhookId,omitempty"`
	Language  Language `protobuf:"varint,4,opt,name=language,proto3,enum=amqp.Language" json:"language,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigurationGetAnswer_TwitterWebhook) Descriptor deprecated added in v0.0.2

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

Deprecated: Use ConfigurationGetAnswer_TwitterWebhook.ProtoReflect.Descriptor instead.

func (*ConfigurationGetAnswer_TwitterWebhook) GetChannelId added in v0.0.2

func (*ConfigurationGetAnswer_TwitterWebhook) GetLanguage added in v0.0.2

func (*ConfigurationGetAnswer_TwitterWebhook) GetName added in v0.0.2

func (*ConfigurationGetAnswer_TwitterWebhook) GetWebhookId added in v0.0.2

func (*ConfigurationGetAnswer_TwitterWebhook) ProtoMessage added in v0.0.2

func (*ConfigurationGetAnswer_TwitterWebhook) ProtoMessage()

func (*ConfigurationGetAnswer_TwitterWebhook) ProtoReflect added in v0.0.2

func (*ConfigurationGetAnswer_TwitterWebhook) Reset added in v0.0.2

func (*ConfigurationGetAnswer_TwitterWebhook) String added in v0.0.2

type ConfigurationGetRequest added in v0.0.2

type ConfigurationGetRequest struct {
	GuildId string `protobuf:"bytes,1,opt,name=guildId,proto3" json:"guildId,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigurationGetRequest) Descriptor deprecated added in v0.0.2

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

Deprecated: Use ConfigurationGetRequest.ProtoReflect.Descriptor instead.

func (*ConfigurationGetRequest) GetGuildId added in v0.0.2

func (x *ConfigurationGetRequest) GetGuildId() string

func (*ConfigurationGetRequest) ProtoMessage added in v0.0.2

func (*ConfigurationGetRequest) ProtoMessage()

func (*ConfigurationGetRequest) ProtoReflect added in v0.0.2

func (x *ConfigurationGetRequest) ProtoReflect() protoreflect.Message

func (*ConfigurationGetRequest) Reset added in v0.0.2

func (x *ConfigurationGetRequest) Reset()

func (*ConfigurationGetRequest) String added in v0.0.2

func (x *ConfigurationGetRequest) String() string

type ConfigurationSetAlmanaxWebhookRequest added in v0.0.2

type ConfigurationSetAlmanaxWebhookRequest struct {
	GuildId      string   `protobuf:"bytes,1,opt,name=guildId,proto3" json:"guildId,omitempty"`
	ChannelId    string   `protobuf:"bytes,2,opt,name=channelId,proto3" json:"channelId,omitempty"`
	WebhookId    string   `protobuf:"bytes,3,opt,name=webhookId,proto3" json:"webhookId,omitempty"`
	WebhookToken string   `protobuf:"bytes,4,opt,name=webhookToken,proto3" json:"webhookToken,omitempty"`
	Enabled      bool     `protobuf:"varint,5,opt,name=enabled,proto3" json:"enabled,omitempty"`
	Language     Language `protobuf:"varint,6,opt,name=language,proto3,enum=amqp.Language" json:"language,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigurationSetAlmanaxWebhookRequest) Descriptor deprecated added in v0.0.2

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

Deprecated: Use ConfigurationSetAlmanaxWebhookRequest.ProtoReflect.Descriptor instead.

func (*ConfigurationSetAlmanaxWebhookRequest) GetChannelId added in v0.0.2

func (*ConfigurationSetAlmanaxWebhookRequest) GetEnabled added in v0.0.2

func (*ConfigurationSetAlmanaxWebhookRequest) GetGuildId added in v0.0.2

func (*ConfigurationSetAlmanaxWebhookRequest) GetLanguage added in v0.0.2

func (*ConfigurationSetAlmanaxWebhookRequest) GetWebhookId added in v0.0.2

func (*ConfigurationSetAlmanaxWebhookRequest) GetWebhookToken added in v0.0.2

func (x *ConfigurationSetAlmanaxWebhookRequest) GetWebhookToken() string

func (*ConfigurationSetAlmanaxWebhookRequest) ProtoMessage added in v0.0.2

func (*ConfigurationSetAlmanaxWebhookRequest) ProtoMessage()

func (*ConfigurationSetAlmanaxWebhookRequest) ProtoReflect added in v0.0.2

func (*ConfigurationSetAlmanaxWebhookRequest) Reset added in v0.0.2

func (*ConfigurationSetAlmanaxWebhookRequest) String added in v0.0.2

type ConfigurationSetAnswer added in v0.0.2

type ConfigurationSetAnswer struct {
	RemoveWebhook bool   `protobuf:"varint,1,opt,name=removeWebhook,proto3" json:"removeWebhook,omitempty"`
	WebhookId     string `protobuf:"bytes,2,opt,name=webhookId,proto3" json:"webhookId,omitempty"`
	WebhookToken  string `protobuf:"bytes,3,opt,name=webhookToken,proto3" json:"webhookToken,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigurationSetAnswer) Descriptor deprecated added in v0.0.2

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

Deprecated: Use ConfigurationSetAnswer.ProtoReflect.Descriptor instead.

func (*ConfigurationSetAnswer) GetRemoveWebhook added in v0.0.2

func (x *ConfigurationSetAnswer) GetRemoveWebhook() bool

func (*ConfigurationSetAnswer) GetWebhookId added in v0.0.2

func (x *ConfigurationSetAnswer) GetWebhookId() string

func (*ConfigurationSetAnswer) GetWebhookToken added in v0.0.2

func (x *ConfigurationSetAnswer) GetWebhookToken() string

func (*ConfigurationSetAnswer) ProtoMessage added in v0.0.2

func (*ConfigurationSetAnswer) ProtoMessage()

func (*ConfigurationSetAnswer) ProtoReflect added in v0.0.2

func (x *ConfigurationSetAnswer) ProtoReflect() protoreflect.Message

func (*ConfigurationSetAnswer) Reset added in v0.0.2

func (x *ConfigurationSetAnswer) Reset()

func (*ConfigurationSetAnswer) String added in v0.0.2

func (x *ConfigurationSetAnswer) String() string

type ConfigurationSetRssWebhookRequest added in v0.0.2

type ConfigurationSetRssWebhookRequest struct {
	GuildId      string   `protobuf:"bytes,1,opt,name=guildId,proto3" json:"guildId,omitempty"`
	ChannelId    string   `protobuf:"bytes,2,opt,name=channelId,proto3" json:"channelId,omitempty"`
	FeedId       string   `protobuf:"bytes,3,opt,name=feedId,proto3" json:"feedId,omitempty"`
	WebhookId    string   `protobuf:"bytes,4,opt,name=webhookId,proto3" json:"webhookId,omitempty"`
	WebhookToken string   `protobuf:"bytes,5,opt,name=webhookToken,proto3" json:"webhookToken,omitempty"`
	Enabled      bool     `protobuf:"varint,6,opt,name=enabled,proto3" json:"enabled,omitempty"`
	Language     Language `protobuf:"varint,7,opt,name=language,proto3,enum=amqp.Language" json:"language,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigurationSetRssWebhookRequest) Descriptor deprecated added in v0.0.2

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

Deprecated: Use ConfigurationSetRssWebhookRequest.ProtoReflect.Descriptor instead.

func (*ConfigurationSetRssWebhookRequest) GetChannelId added in v0.0.2

func (x *ConfigurationSetRssWebhookRequest) GetChannelId() string

func (*ConfigurationSetRssWebhookRequest) GetEnabled added in v0.0.2

func (x *ConfigurationSetRssWebhookRequest) GetEnabled() bool

func (*ConfigurationSetRssWebhookRequest) GetFeedId added in v0.0.2

func (*ConfigurationSetRssWebhookRequest) GetGuildId added in v0.0.2

func (x *ConfigurationSetRssWebhookRequest) GetGuildId() string

func (*ConfigurationSetRssWebhookRequest) GetLanguage added in v0.0.2

func (*ConfigurationSetRssWebhookRequest) GetWebhookId added in v0.0.2

func (x *ConfigurationSetRssWebhookRequest) GetWebhookId() string

func (*ConfigurationSetRssWebhookRequest) GetWebhookToken added in v0.0.2

func (x *ConfigurationSetRssWebhookRequest) GetWebhookToken() string

func (*ConfigurationSetRssWebhookRequest) ProtoMessage added in v0.0.2

func (*ConfigurationSetRssWebhookRequest) ProtoMessage()

func (*ConfigurationSetRssWebhookRequest) ProtoReflect added in v0.0.2

func (*ConfigurationSetRssWebhookRequest) Reset added in v0.0.2

func (*ConfigurationSetRssWebhookRequest) String added in v0.0.2

type ConfigurationSetServerRequest added in v0.0.2

type ConfigurationSetServerRequest struct {
	GuildId   string `protobuf:"bytes,1,opt,name=guildId,proto3" json:"guildId,omitempty"`
	ChannelId string `protobuf:"bytes,2,opt,name=channelId,proto3" json:"channelId,omitempty"`
	ServerId  string `protobuf:"bytes,3,opt,name=serverId,proto3" json:"serverId,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigurationSetServerRequest) Descriptor deprecated added in v0.0.2

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

Deprecated: Use ConfigurationSetServerRequest.ProtoReflect.Descriptor instead.

func (*ConfigurationSetServerRequest) GetChannelId added in v0.0.2

func (x *ConfigurationSetServerRequest) GetChannelId() string

func (*ConfigurationSetServerRequest) GetGuildId added in v0.0.2

func (x *ConfigurationSetServerRequest) GetGuildId() string

func (*ConfigurationSetServerRequest) GetServerId added in v0.0.2

func (x *ConfigurationSetServerRequest) GetServerId() string

func (*ConfigurationSetServerRequest) ProtoMessage added in v0.0.2

func (*ConfigurationSetServerRequest) ProtoMessage()

func (*ConfigurationSetServerRequest) ProtoReflect added in v0.0.2

func (*ConfigurationSetServerRequest) Reset added in v0.0.2

func (x *ConfigurationSetServerRequest) Reset()

func (*ConfigurationSetServerRequest) String added in v0.0.2

type ConfigurationSetTwitterWebhookRequest added in v0.0.2

type ConfigurationSetTwitterWebhookRequest struct {
	GuildId      string   `protobuf:"bytes,1,opt,name=guildId,proto3" json:"guildId,omitempty"`
	ChannelId    string   `protobuf:"bytes,2,opt,name=channelId,proto3" json:"channelId,omitempty"`
	WebhookId    string   `protobuf:"bytes,3,opt,name=webhookId,proto3" json:"webhookId,omitempty"`
	WebhookToken string   `protobuf:"bytes,4,opt,name=webhookToken,proto3" json:"webhookToken,omitempty"`
	Enabled      bool     `protobuf:"varint,5,opt,name=enabled,proto3" json:"enabled,omitempty"`
	Language     Language `protobuf:"varint,6,opt,name=language,proto3,enum=amqp.Language" json:"language,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigurationSetTwitterWebhookRequest) Descriptor deprecated added in v0.0.2

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

Deprecated: Use ConfigurationSetTwitterWebhookRequest.ProtoReflect.Descriptor instead.

func (*ConfigurationSetTwitterWebhookRequest) GetChannelId added in v0.0.2

func (*ConfigurationSetTwitterWebhookRequest) GetEnabled added in v0.0.2

func (*ConfigurationSetTwitterWebhookRequest) GetGuildId added in v0.0.2

func (*ConfigurationSetTwitterWebhookRequest) GetLanguage added in v0.0.2

func (*ConfigurationSetTwitterWebhookRequest) GetWebhookId added in v0.0.2

func (*ConfigurationSetTwitterWebhookRequest) GetWebhookToken added in v0.0.2

func (x *ConfigurationSetTwitterWebhookRequest) GetWebhookToken() string

func (*ConfigurationSetTwitterWebhookRequest) ProtoMessage added in v0.0.2

func (*ConfigurationSetTwitterWebhookRequest) ProtoMessage()

func (*ConfigurationSetTwitterWebhookRequest) ProtoReflect added in v0.0.2

func (*ConfigurationSetTwitterWebhookRequest) Reset added in v0.0.2

func (*ConfigurationSetTwitterWebhookRequest) String added in v0.0.2

type ContextKey added in v0.0.2

type ContextKey string

type Exchange added in v0.0.2

type Exchange string

type Impl added in v0.0.2

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

func New

func New(clientID, address string, bindings []Binding) (*Impl, error)

- clientID: ID used to be identified as a publisher/consumer - address: string with the following format: `amqp://username:password@hostname:port/vhost` - topics: topics used to publish and consume messages - bindings: topic, routingKey and queue used to consume messages.

func (*Impl) Consume added in v0.0.2

func (broker *Impl) Consume(queueName string, consumer MessageConsumer) error

func (*Impl) IsConnected added in v0.0.2

func (broker *Impl) IsConnected() bool

func (*Impl) Publish added in v0.0.2

func (broker *Impl) Publish(msg *RabbitMQMessage, exchange Exchange, routingKey, correlationID string) error

func (*Impl) Shutdown added in v0.0.2

func (broker *Impl) Shutdown()

type JobGetBookAnswer added in v0.0.2

type JobGetBookAnswer struct {
	JobId     string                        `protobuf:"bytes,1,opt,name=jobId,proto3" json:"jobId,omitempty"`
	ServerId  string                        `protobuf:"bytes,2,opt,name=serverId,proto3" json:"serverId,omitempty"`
	Craftsmen []*JobGetBookAnswer_Craftsman `protobuf:"bytes,3,rep,name=craftsmen,proto3" json:"craftsmen,omitempty"`
	// contains filtered or unexported fields
}

func (*JobGetBookAnswer) Descriptor deprecated added in v0.0.2

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

Deprecated: Use JobGetBookAnswer.ProtoReflect.Descriptor instead.

func (*JobGetBookAnswer) GetCraftsmen added in v0.0.2

func (x *JobGetBookAnswer) GetCraftsmen() []*JobGetBookAnswer_Craftsman

func (*JobGetBookAnswer) GetJobId added in v0.0.2

func (x *JobGetBookAnswer) GetJobId() string

func (*JobGetBookAnswer) GetServerId added in v0.0.2

func (x *JobGetBookAnswer) GetServerId() string

func (*JobGetBookAnswer) ProtoMessage added in v0.0.2

func (*JobGetBookAnswer) ProtoMessage()

func (*JobGetBookAnswer) ProtoReflect added in v0.0.2

func (x *JobGetBookAnswer) ProtoReflect() protoreflect.Message

func (*JobGetBookAnswer) Reset added in v0.0.2

func (x *JobGetBookAnswer) Reset()

func (*JobGetBookAnswer) String added in v0.0.2

func (x *JobGetBookAnswer) String() string

type JobGetBookAnswer_Craftsman added in v0.0.2

type JobGetBookAnswer_Craftsman struct {
	UserId string `protobuf:"bytes,1,opt,name=userId,proto3" json:"userId,omitempty"`
	Level  int64  `protobuf:"varint,2,opt,name=level,proto3" json:"level,omitempty"`
	// contains filtered or unexported fields
}

func (*JobGetBookAnswer_Craftsman) Descriptor deprecated added in v0.0.2

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

Deprecated: Use JobGetBookAnswer_Craftsman.ProtoReflect.Descriptor instead.

func (*JobGetBookAnswer_Craftsman) GetLevel added in v0.0.2

func (x *JobGetBookAnswer_Craftsman) GetLevel() int64

func (*JobGetBookAnswer_Craftsman) GetUserId added in v0.0.2

func (x *JobGetBookAnswer_Craftsman) GetUserId() string

func (*JobGetBookAnswer_Craftsman) ProtoMessage added in v0.0.2

func (*JobGetBookAnswer_Craftsman) ProtoMessage()

func (*JobGetBookAnswer_Craftsman) ProtoReflect added in v0.0.2

func (*JobGetBookAnswer_Craftsman) Reset added in v0.0.2

func (x *JobGetBookAnswer_Craftsman) Reset()

func (*JobGetBookAnswer_Craftsman) String added in v0.0.2

func (x *JobGetBookAnswer_Craftsman) String() string

type JobGetBookRequest added in v0.0.2

type JobGetBookRequest struct {
	UserIds  []string `protobuf:"bytes,1,rep,name=userIds,proto3" json:"userIds,omitempty"`
	JobId    string   `protobuf:"bytes,2,opt,name=jobId,proto3" json:"jobId,omitempty"`
	ServerId string   `protobuf:"bytes,3,opt,name=serverId,proto3" json:"serverId,omitempty"`
	Limit    int64    `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*JobGetBookRequest) Descriptor deprecated added in v0.0.2

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

Deprecated: Use JobGetBookRequest.ProtoReflect.Descriptor instead.

func (*JobGetBookRequest) GetJobId added in v0.0.2

func (x *JobGetBookRequest) GetJobId() string

func (*JobGetBookRequest) GetLimit added in v0.0.2

func (x *JobGetBookRequest) GetLimit() int64

func (*JobGetBookRequest) GetServerId added in v0.0.2

func (x *JobGetBookRequest) GetServerId() string

func (*JobGetBookRequest) GetUserIds added in v0.0.2

func (x *JobGetBookRequest) GetUserIds() []string

func (*JobGetBookRequest) ProtoMessage added in v0.0.2

func (*JobGetBookRequest) ProtoMessage()

func (*JobGetBookRequest) ProtoReflect added in v0.0.2

func (x *JobGetBookRequest) ProtoReflect() protoreflect.Message

func (*JobGetBookRequest) Reset added in v0.0.2

func (x *JobGetBookRequest) Reset()

func (*JobGetBookRequest) String added in v0.0.2

func (x *JobGetBookRequest) String() string

type JobGetUserAnswer added in v0.0.2

type JobGetUserAnswer struct {
	ServerId string                            `protobuf:"bytes,1,opt,name=serverId,proto3" json:"serverId,omitempty"`
	Jobs     []*JobGetUserAnswer_JobExperience `protobuf:"bytes,2,rep,name=jobs,proto3" json:"jobs,omitempty"`
	// contains filtered or unexported fields
}

func (*JobGetUserAnswer) Descriptor deprecated added in v0.0.2

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

Deprecated: Use JobGetUserAnswer.ProtoReflect.Descriptor instead.

func (*JobGetUserAnswer) GetJobs added in v0.0.2

func (*JobGetUserAnswer) GetServerId added in v0.0.2

func (x *JobGetUserAnswer) GetServerId() string

func (*JobGetUserAnswer) ProtoMessage added in v0.0.2

func (*JobGetUserAnswer) ProtoMessage()

func (*JobGetUserAnswer) ProtoReflect added in v0.0.2

func (x *JobGetUserAnswer) ProtoReflect() protoreflect.Message

func (*JobGetUserAnswer) Reset added in v0.0.2

func (x *JobGetUserAnswer) Reset()

func (*JobGetUserAnswer) String added in v0.0.2

func (x *JobGetUserAnswer) String() string

type JobGetUserAnswer_JobExperience added in v0.0.2

type JobGetUserAnswer_JobExperience struct {
	JobId string `protobuf:"bytes,1,opt,name=jobId,proto3" json:"jobId,omitempty"`
	Level int64  `protobuf:"varint,2,opt,name=level,proto3" json:"level,omitempty"`
	// contains filtered or unexported fields
}

func (*JobGetUserAnswer_JobExperience) Descriptor deprecated added in v0.0.2

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

Deprecated: Use JobGetUserAnswer_JobExperience.ProtoReflect.Descriptor instead.

func (*JobGetUserAnswer_JobExperience) GetJobId added in v0.0.2

func (x *JobGetUserAnswer_JobExperience) GetJobId() string

func (*JobGetUserAnswer_JobExperience) GetLevel added in v0.0.2

func (x *JobGetUserAnswer_JobExperience) GetLevel() int64

func (*JobGetUserAnswer_JobExperience) ProtoMessage added in v0.0.2

func (*JobGetUserAnswer_JobExperience) ProtoMessage()

func (*JobGetUserAnswer_JobExperience) ProtoReflect added in v0.0.2

func (*JobGetUserAnswer_JobExperience) Reset added in v0.0.2

func (x *JobGetUserAnswer_JobExperience) Reset()

func (*JobGetUserAnswer_JobExperience) String added in v0.0.2

type JobGetUserRequest added in v0.0.2

type JobGetUserRequest struct {
	UserId   string `protobuf:"bytes,1,opt,name=userId,proto3" json:"userId,omitempty"`
	ServerId string `protobuf:"bytes,2,opt,name=serverId,proto3" json:"serverId,omitempty"`
	// contains filtered or unexported fields
}

func (*JobGetUserRequest) Descriptor deprecated added in v0.0.2

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

Deprecated: Use JobGetUserRequest.ProtoReflect.Descriptor instead.

func (*JobGetUserRequest) GetServerId added in v0.0.2

func (x *JobGetUserRequest) GetServerId() string

func (*JobGetUserRequest) GetUserId added in v0.0.2

func (x *JobGetUserRequest) GetUserId() string

func (*JobGetUserRequest) ProtoMessage added in v0.0.2

func (*JobGetUserRequest) ProtoMessage()

func (*JobGetUserRequest) ProtoReflect added in v0.0.2

func (x *JobGetUserRequest) ProtoReflect() protoreflect.Message

func (*JobGetUserRequest) Reset added in v0.0.2

func (x *JobGetUserRequest) Reset()

func (*JobGetUserRequest) String added in v0.0.2

func (x *JobGetUserRequest) String() string

type JobSetAnswer added in v0.0.2

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

func (*JobSetAnswer) Descriptor deprecated added in v0.0.2

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

Deprecated: Use JobSetAnswer.ProtoReflect.Descriptor instead.

func (*JobSetAnswer) ProtoMessage added in v0.0.2

func (*JobSetAnswer) ProtoMessage()

func (*JobSetAnswer) ProtoReflect added in v0.0.2

func (x *JobSetAnswer) ProtoReflect() protoreflect.Message

func (*JobSetAnswer) Reset added in v0.0.2

func (x *JobSetAnswer) Reset()

func (*JobSetAnswer) String added in v0.0.2

func (x *JobSetAnswer) String() string

type JobSetRequest added in v0.0.2

type JobSetRequest struct {
	UserId   string `protobuf:"bytes,1,opt,name=userId,proto3" json:"userId,omitempty"`
	JobId    string `protobuf:"bytes,2,opt,name=jobId,proto3" json:"jobId,omitempty"`
	ServerId string `protobuf:"bytes,3,opt,name=serverId,proto3" json:"serverId,omitempty"`
	Level    int64  `protobuf:"varint,4,opt,name=level,proto3" json:"level,omitempty"`
	// contains filtered or unexported fields
}

func (*JobSetRequest) Descriptor deprecated added in v0.0.2

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

Deprecated: Use JobSetRequest.ProtoReflect.Descriptor instead.

func (*JobSetRequest) GetJobId added in v0.0.2

func (x *JobSetRequest) GetJobId() string

func (*JobSetRequest) GetLevel added in v0.0.2

func (x *JobSetRequest) GetLevel() int64

func (*JobSetRequest) GetServerId added in v0.0.2

func (x *JobSetRequest) GetServerId() string

func (*JobSetRequest) GetUserId added in v0.0.2

func (x *JobSetRequest) GetUserId() string

func (*JobSetRequest) ProtoMessage added in v0.0.2

func (*JobSetRequest) ProtoMessage()

func (*JobSetRequest) ProtoReflect added in v0.0.2

func (x *JobSetRequest) ProtoReflect() protoreflect.Message

func (*JobSetRequest) Reset added in v0.0.2

func (x *JobSetRequest) Reset()

func (*JobSetRequest) String added in v0.0.2

func (x *JobSetRequest) String() string

type Language added in v0.0.2

type Language int32
const (
	Language_ANY Language = 0
	Language_FR  Language = 1
	Language_EN  Language = 2
	Language_ES  Language = 3
)

func (Language) Descriptor added in v0.0.2

func (Language) Descriptor() protoreflect.EnumDescriptor

func (Language) Enum added in v0.0.2

func (x Language) Enum() *Language

func (Language) EnumDescriptor deprecated added in v0.0.2

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

Deprecated: Use Language.Descriptor instead.

func (Language) Number added in v0.0.2

func (x Language) Number() protoreflect.EnumNumber

func (Language) String added in v0.0.2

func (x Language) String() string

func (Language) Type added in v0.0.2

type MessageBroker

type MessageBroker interface {
	Publish(msg *RabbitMQMessage, exchange Exchange, routingKey, correlationID string) error
	Consume(queueName string, consumer MessageConsumer) error
	IsConnected() bool
	Shutdown()
}

type MessageConsumer added in v0.0.2

type MessageConsumer func(ctx context.Context, message *RabbitMQMessage, correlationID string)

type Mock added in v0.0.2

type Mock struct {
	PublishFunc     func(msg *RabbitMQMessage, exchange Exchange, routingKey, correlationID string) error
	ConsumeFunc     func(queueName, routingKey string, consumer MessageConsumer) error
	IsConnectedFunc func() bool
	ShutdownFunc    func()
}

func (*Mock) Consume added in v0.0.2

func (mock *Mock) Consume(queueName, routingKey string, consumer MessageConsumer) error

func (*Mock) IsConnected added in v0.0.2

func (mock *Mock) IsConnected() bool

func (*Mock) Publish added in v0.0.2

func (mock *Mock) Publish(msg *RabbitMQMessage, exchange Exchange, routingKey, correlationID string) error

func (*Mock) Shutdown added in v0.0.2

func (mock *Mock) Shutdown()

type NewsRSSMessage

type NewsRSSMessage struct {
	Title      string               `protobuf:"bytes,1,opt,name=title,proto3" json:"title,omitempty"`
	AuthorName string               `protobuf:"bytes,2,opt,name=authorName,proto3" json:"authorName,omitempty"`
	Url        string               `protobuf:"bytes,3,opt,name=url,proto3" json:"url,omitempty"`
	IconUrl    string               `protobuf:"bytes,4,opt,name=iconUrl,proto3" json:"iconUrl,omitempty"`
	Date       *timestamp.Timestamp `protobuf:"bytes,5,opt,name=date,proto3" json:"date,omitempty"`
	Type       string               `protobuf:"bytes,6,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*NewsRSSMessage) Descriptor deprecated

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

Deprecated: Use NewsRSSMessage.ProtoReflect.Descriptor instead.

func (*NewsRSSMessage) GetAuthorName added in v0.0.2

func (x *NewsRSSMessage) GetAuthorName() string

func (*NewsRSSMessage) GetDate

func (x *NewsRSSMessage) GetDate() *timestamp.Timestamp

func (*NewsRSSMessage) GetIconUrl

func (x *NewsRSSMessage) GetIconUrl() string

func (*NewsRSSMessage) GetTitle

func (x *NewsRSSMessage) GetTitle() string

func (*NewsRSSMessage) GetType added in v0.0.2

func (x *NewsRSSMessage) GetType() string

func (*NewsRSSMessage) GetUrl

func (x *NewsRSSMessage) GetUrl() string

func (*NewsRSSMessage) ProtoMessage

func (*NewsRSSMessage) ProtoMessage()

func (*NewsRSSMessage) ProtoReflect

func (x *NewsRSSMessage) ProtoReflect() protoreflect.Message

func (*NewsRSSMessage) Reset

func (x *NewsRSSMessage) Reset()

func (*NewsRSSMessage) String

func (x *NewsRSSMessage) String() string

type NewsTwitterMessage

type NewsTwitterMessage struct {
	Url  string               `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	Date *timestamp.Timestamp `protobuf:"bytes,2,opt,name=date,proto3" json:"date,omitempty"`
	// contains filtered or unexported fields
}

func (*NewsTwitterMessage) Descriptor deprecated

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

Deprecated: Use NewsTwitterMessage.ProtoReflect.Descriptor instead.

func (*NewsTwitterMessage) GetDate added in v0.0.2

func (x *NewsTwitterMessage) GetDate() *timestamp.Timestamp

func (*NewsTwitterMessage) GetUrl

func (x *NewsTwitterMessage) GetUrl() string

func (*NewsTwitterMessage) ProtoMessage

func (*NewsTwitterMessage) ProtoMessage()

func (*NewsTwitterMessage) ProtoReflect

func (x *NewsTwitterMessage) ProtoReflect() protoreflect.Message

func (*NewsTwitterMessage) Reset

func (x *NewsTwitterMessage) Reset()

func (*NewsTwitterMessage) String

func (x *NewsTwitterMessage) String() string

type PortalPositionAnswer added in v0.0.2

type PortalPositionAnswer struct {
	Positions []*PortalPositionAnswer_PortalPosition `protobuf:"bytes,1,rep,name=positions,proto3" json:"positions,omitempty"`
	// contains filtered or unexported fields
}

func (*PortalPositionAnswer) Descriptor deprecated added in v0.0.2

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

Deprecated: Use PortalPositionAnswer.ProtoReflect.Descriptor instead.

func (*PortalPositionAnswer) GetPositions added in v0.0.2

func (*PortalPositionAnswer) ProtoMessage added in v0.0.2

func (*PortalPositionAnswer) ProtoMessage()

func (*PortalPositionAnswer) ProtoReflect added in v0.0.2

func (x *PortalPositionAnswer) ProtoReflect() protoreflect.Message

func (*PortalPositionAnswer) Reset added in v0.0.2

func (x *PortalPositionAnswer) Reset()

func (*PortalPositionAnswer) String added in v0.0.2

func (x *PortalPositionAnswer) String() string

type PortalPositionAnswer_PortalPosition added in v0.0.2

type PortalPositionAnswer_PortalPosition struct {
	ServerId      string                                        `protobuf:"bytes,1,opt,name=serverId,proto3" json:"serverId,omitempty"`
	DimensionId   string                                        `protobuf:"bytes,2,opt,name=dimensionId,proto3" json:"dimensionId,omitempty"`
	RemainingUses int32                                         `protobuf:"varint,3,opt,name=remainingUses,proto3" json:"remainingUses,omitempty"`
	Position      *PortalPositionAnswer_PortalPosition_Position `protobuf:"bytes,4,opt,name=position,proto3" json:"position,omitempty"`
	CreatedBy     string                                        `protobuf:"bytes,5,opt,name=createdBy,proto3" json:"createdBy,omitempty"`
	UpdatedBy     string                                        `protobuf:"bytes,6,opt,name=updatedBy,proto3" json:"updatedBy,omitempty"`
	CreatedAt     *timestamp.Timestamp                          `protobuf:"bytes,7,opt,name=createdAt,proto3" json:"createdAt,omitempty"`
	UpdatedAt     *timestamp.Timestamp                          `protobuf:"bytes,8,opt,name=updatedAt,proto3" json:"updatedAt,omitempty"`
	Source        *PortalPositionAnswer_PortalPosition_Source   `protobuf:"bytes,9,opt,name=source,proto3" json:"source,omitempty"`
	// contains filtered or unexported fields
}

func (*PortalPositionAnswer_PortalPosition) Descriptor deprecated added in v0.0.2

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

Deprecated: Use PortalPositionAnswer_PortalPosition.ProtoReflect.Descriptor instead.

func (*PortalPositionAnswer_PortalPosition) GetCreatedAt added in v0.0.2

func (*PortalPositionAnswer_PortalPosition) GetCreatedBy added in v0.0.2

func (x *PortalPositionAnswer_PortalPosition) GetCreatedBy() string

func (*PortalPositionAnswer_PortalPosition) GetDimensionId added in v0.0.2

func (x *PortalPositionAnswer_PortalPosition) GetDimensionId() string

func (*PortalPositionAnswer_PortalPosition) GetPosition added in v0.0.2

func (*PortalPositionAnswer_PortalPosition) GetRemainingUses added in v0.0.2

func (x *PortalPositionAnswer_PortalPosition) GetRemainingUses() int32

func (*PortalPositionAnswer_PortalPosition) GetServerId added in v0.0.2

func (*PortalPositionAnswer_PortalPosition) GetSource added in v0.0.2

func (*PortalPositionAnswer_PortalPosition) GetUpdatedAt added in v0.0.2

func (*PortalPositionAnswer_PortalPosition) GetUpdatedBy added in v0.0.2

func (x *PortalPositionAnswer_PortalPosition) GetUpdatedBy() string

func (*PortalPositionAnswer_PortalPosition) ProtoMessage added in v0.0.2

func (*PortalPositionAnswer_PortalPosition) ProtoMessage()

func (*PortalPositionAnswer_PortalPosition) ProtoReflect added in v0.0.2

func (*PortalPositionAnswer_PortalPosition) Reset added in v0.0.2

func (*PortalPositionAnswer_PortalPosition) String added in v0.0.2

type PortalPositionAnswer_PortalPosition_Position added in v0.0.2

type PortalPositionAnswer_PortalPosition_Position struct {
	X                    int32                                                   `protobuf:"varint,1,opt,name=x,proto3" json:"x,omitempty"`
	Y                    int32                                                   `protobuf:"varint,2,opt,name=y,proto3" json:"y,omitempty"`
	IsInCanopy           bool                                                    `protobuf:"varint,3,opt,name=isInCanopy,proto3" json:"isInCanopy,omitempty"`
	Transport            *PortalPositionAnswer_PortalPosition_Position_Transport `protobuf:"bytes,4,opt,name=transport,proto3" json:"transport,omitempty"`
	ConditionalTransport *PortalPositionAnswer_PortalPosition_Position_Transport `protobuf:"bytes,5,opt,name=conditionalTransport,proto3" json:"conditionalTransport,omitempty"`
	// contains filtered or unexported fields
}

func (*PortalPositionAnswer_PortalPosition_Position) Descriptor deprecated added in v0.0.2

Deprecated: Use PortalPositionAnswer_PortalPosition_Position.ProtoReflect.Descriptor instead.

func (*PortalPositionAnswer_PortalPosition_Position) GetConditionalTransport added in v0.0.2

func (*PortalPositionAnswer_PortalPosition_Position) GetIsInCanopy added in v0.0.2

func (*PortalPositionAnswer_PortalPosition_Position) GetTransport added in v0.0.2

func (*PortalPositionAnswer_PortalPosition_Position) GetX added in v0.0.2

func (*PortalPositionAnswer_PortalPosition_Position) GetY added in v0.0.2

func (*PortalPositionAnswer_PortalPosition_Position) ProtoMessage added in v0.0.2

func (*PortalPositionAnswer_PortalPosition_Position) ProtoReflect added in v0.0.2

func (*PortalPositionAnswer_PortalPosition_Position) Reset added in v0.0.2

func (*PortalPositionAnswer_PortalPosition_Position) String added in v0.0.2

type PortalPositionAnswer_PortalPosition_Position_Transport added in v0.0.2

type PortalPositionAnswer_PortalPosition_Position_Transport struct {
	AreaId    string `protobuf:"bytes,1,opt,name=areaId,proto3" json:"areaId,omitempty"`
	SubAreaId string `protobuf:"bytes,2,opt,name=subAreaId,proto3" json:"subAreaId,omitempty"`
	TypeId    string `protobuf:"bytes,3,opt,name=typeId,proto3" json:"typeId,omitempty"`
	X         int32  `protobuf:"varint,4,opt,name=x,proto3" json:"x,omitempty"`
	Y         int32  `protobuf:"varint,5,opt,name=y,proto3" json:"y,omitempty"`
	// contains filtered or unexported fields
}

func (*PortalPositionAnswer_PortalPosition_Position_Transport) Descriptor deprecated added in v0.0.2

Deprecated: Use PortalPositionAnswer_PortalPosition_Position_Transport.ProtoReflect.Descriptor instead.

func (*PortalPositionAnswer_PortalPosition_Position_Transport) GetAreaId added in v0.0.2

func (*PortalPositionAnswer_PortalPosition_Position_Transport) GetSubAreaId added in v0.0.2

func (*PortalPositionAnswer_PortalPosition_Position_Transport) GetTypeId added in v0.0.2

func (*PortalPositionAnswer_PortalPosition_Position_Transport) GetX added in v0.0.2

func (*PortalPositionAnswer_PortalPosition_Position_Transport) GetY added in v0.0.2

func (*PortalPositionAnswer_PortalPosition_Position_Transport) ProtoMessage added in v0.0.2

func (*PortalPositionAnswer_PortalPosition_Position_Transport) ProtoReflect added in v0.0.2

func (*PortalPositionAnswer_PortalPosition_Position_Transport) Reset added in v0.0.2

func (*PortalPositionAnswer_PortalPosition_Position_Transport) String added in v0.0.2

type PortalPositionAnswer_PortalPosition_Source added in v0.0.2

type PortalPositionAnswer_PortalPosition_Source struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Icon string `protobuf:"bytes,2,opt,name=icon,proto3" json:"icon,omitempty"`
	Url  string `protobuf:"bytes,3,opt,name=url,proto3" json:"url,omitempty"`
	// contains filtered or unexported fields
}

func (*PortalPositionAnswer_PortalPosition_Source) Descriptor deprecated added in v0.0.2

Deprecated: Use PortalPositionAnswer_PortalPosition_Source.ProtoReflect.Descriptor instead.

func (*PortalPositionAnswer_PortalPosition_Source) GetIcon added in v0.0.2

func (*PortalPositionAnswer_PortalPosition_Source) GetName added in v0.0.2

func (*PortalPositionAnswer_PortalPosition_Source) GetUrl added in v0.0.2

func (*PortalPositionAnswer_PortalPosition_Source) ProtoMessage added in v0.0.2

func (*PortalPositionAnswer_PortalPosition_Source) ProtoReflect added in v0.0.2

func (*PortalPositionAnswer_PortalPosition_Source) Reset added in v0.0.2

func (*PortalPositionAnswer_PortalPosition_Source) String added in v0.0.2

type PortalPositionRequest added in v0.0.2

type PortalPositionRequest struct {
	ServerId    string `protobuf:"bytes,1,opt,name=serverId,proto3" json:"serverId,omitempty"`
	DimensionId string `protobuf:"bytes,2,opt,name=dimensionId,proto3" json:"dimensionId,omitempty"`
	// contains filtered or unexported fields
}

func (*PortalPositionRequest) Descriptor deprecated added in v0.0.2

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

Deprecated: Use PortalPositionRequest.ProtoReflect.Descriptor instead.

func (*PortalPositionRequest) GetDimensionId added in v0.0.2

func (x *PortalPositionRequest) GetDimensionId() string

func (*PortalPositionRequest) GetServerId added in v0.0.2

func (x *PortalPositionRequest) GetServerId() string

func (*PortalPositionRequest) ProtoMessage added in v0.0.2

func (*PortalPositionRequest) ProtoMessage()

func (*PortalPositionRequest) ProtoReflect added in v0.0.2

func (x *PortalPositionRequest) ProtoReflect() protoreflect.Message

func (*PortalPositionRequest) Reset added in v0.0.2

func (x *PortalPositionRequest) Reset()

func (*PortalPositionRequest) String added in v0.0.2

func (x *PortalPositionRequest) String() string

type RabbitMQMessage

type RabbitMQMessage struct {
	Type                                  RabbitMQMessage_Type                   `protobuf:"varint,1,opt,name=type,proto3,enum=amqp.RabbitMQMessage_Type" json:"type,omitempty"`
	Language                              Language                               `protobuf:"varint,2,opt,name=language,proto3,enum=amqp.Language" json:"language,omitempty"`
	Status                                RabbitMQMessage_Status                 `protobuf:"varint,3,opt,name=status,proto3,enum=amqp.RabbitMQMessage_Status" json:"status,omitempty"`
	NewsTwitterMessage                    *NewsTwitterMessage                    `protobuf:"bytes,100,opt,name=newsTwitterMessage,proto3" json:"newsTwitterMessage,omitempty"`
	NewsRSSMessage                        *NewsRSSMessage                        `protobuf:"bytes,101,opt,name=newsRSSMessage,proto3" json:"newsRSSMessage,omitempty"`
	PortalPositionRequest                 *PortalPositionRequest                 `protobuf:"bytes,200,opt,name=portalPositionRequest,proto3" json:"portalPositionRequest,omitempty"`
	PortalPositionAnswer                  *PortalPositionAnswer                  `protobuf:"bytes,201,opt,name=portalPositionAnswer,proto3" json:"portalPositionAnswer,omitempty"`
	ConfigurationGetRequest               *ConfigurationGetRequest               `protobuf:"bytes,300,opt,name=configurationGetRequest,proto3" json:"configurationGetRequest,omitempty"`
	ConfigurationGetAnswer                *ConfigurationGetAnswer                `protobuf:"bytes,301,opt,name=configurationGetAnswer,proto3" json:"configurationGetAnswer,omitempty"`
	ConfigurationSetServerRequest         *ConfigurationSetServerRequest         `protobuf:"bytes,302,opt,name=configurationSetServerRequest,proto3" json:"configurationSetServerRequest,omitempty"`
	ConfigurationSetAlmanaxWebhookRequest *ConfigurationSetAlmanaxWebhookRequest `` /* 129-byte string literal not displayed */
	ConfigurationSetRssWebhookRequest     *ConfigurationSetRssWebhookRequest     `protobuf:"bytes,304,opt,name=configurationSetRssWebhookRequest,proto3" json:"configurationSetRssWebhookRequest,omitempty"`
	ConfigurationSetTwitterWebhookRequest *ConfigurationSetTwitterWebhookRequest `` /* 129-byte string literal not displayed */
	ConfigurationSetAnswer                *ConfigurationSetAnswer                `protobuf:"bytes,306,opt,name=configurationSetAnswer,proto3" json:"configurationSetAnswer,omitempty"`
	JobGetBookRequest                     *JobGetBookRequest                     `protobuf:"bytes,400,opt,name=jobGetBookRequest,proto3" json:"jobGetBookRequest,omitempty"`
	JobGetBookAnswer                      *JobGetBookAnswer                      `protobuf:"bytes,401,opt,name=jobGetBookAnswer,proto3" json:"jobGetBookAnswer,omitempty"`
	JobGetUserRequest                     *JobGetUserRequest                     `protobuf:"bytes,402,opt,name=jobGetUserRequest,proto3" json:"jobGetUserRequest,omitempty"`
	JobGetUserAnswer                      *JobGetUserAnswer                      `protobuf:"bytes,403,opt,name=jobGetUserAnswer,proto3" json:"jobGetUserAnswer,omitempty"`
	JobSetRequest                         *JobSetRequest                         `protobuf:"bytes,404,opt,name=jobSetRequest,proto3" json:"jobSetRequest,omitempty"`
	JobSetAnswer                          *JobSetAnswer                          `protobuf:"bytes,405,opt,name=jobSetAnswer,proto3" json:"jobSetAnswer,omitempty"`
	AlignGetBookRequest                   *AlignGetBookRequest                   `protobuf:"bytes,500,opt,name=alignGetBookRequest,proto3" json:"alignGetBookRequest,omitempty"`
	AlignGetBookAnswer                    *AlignGetBookAnswer                    `protobuf:"bytes,501,opt,name=alignGetBookAnswer,proto3" json:"alignGetBookAnswer,omitempty"`
	AlignGetUserRequest                   *AlignGetUserRequest                   `protobuf:"bytes,502,opt,name=alignGetUserRequest,proto3" json:"alignGetUserRequest,omitempty"`
	AlignGetUserAnswer                    *AlignGetUserAnswer                    `protobuf:"bytes,503,opt,name=alignGetUserAnswer,proto3" json:"alignGetUserAnswer,omitempty"`
	AlignSetRequest                       *AlignSetRequest                       `protobuf:"bytes,504,opt,name=alignSetRequest,proto3" json:"alignSetRequest,omitempty"`
	AlignSetAnswer                        *AlignSetAnswer                        `protobuf:"bytes,505,opt,name=alignSetAnswer,proto3" json:"alignSetAnswer,omitempty"`
	// contains filtered or unexported fields
}

func (*RabbitMQMessage) Descriptor deprecated

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

Deprecated: Use RabbitMQMessage.ProtoReflect.Descriptor instead.

func (*RabbitMQMessage) GetAlignGetBookAnswer added in v0.0.2

func (x *RabbitMQMessage) GetAlignGetBookAnswer() *AlignGetBookAnswer

func (*RabbitMQMessage) GetAlignGetBookRequest added in v0.0.2

func (x *RabbitMQMessage) GetAlignGetBookRequest() *AlignGetBookRequest

func (*RabbitMQMessage) GetAlignGetUserAnswer added in v0.0.2

func (x *RabbitMQMessage) GetAlignGetUserAnswer() *AlignGetUserAnswer

func (*RabbitMQMessage) GetAlignGetUserRequest added in v0.0.2

func (x *RabbitMQMessage) GetAlignGetUserRequest() *AlignGetUserRequest

func (*RabbitMQMessage) GetAlignSetAnswer added in v0.0.2

func (x *RabbitMQMessage) GetAlignSetAnswer() *AlignSetAnswer

func (*RabbitMQMessage) GetAlignSetRequest added in v0.0.2

func (x *RabbitMQMessage) GetAlignSetRequest() *AlignSetRequest

func (*RabbitMQMessage) GetConfigurationGetAnswer added in v0.0.2

func (x *RabbitMQMessage) GetConfigurationGetAnswer() *ConfigurationGetAnswer

func (*RabbitMQMessage) GetConfigurationGetRequest added in v0.0.2

func (x *RabbitMQMessage) GetConfigurationGetRequest() *ConfigurationGetRequest

func (*RabbitMQMessage) GetConfigurationSetAlmanaxWebhookRequest added in v0.0.2

func (x *RabbitMQMessage) GetConfigurationSetAlmanaxWebhookRequest() *ConfigurationSetAlmanaxWebhookRequest

func (*RabbitMQMessage) GetConfigurationSetAnswer added in v0.0.2

func (x *RabbitMQMessage) GetConfigurationSetAnswer() *ConfigurationSetAnswer

func (*RabbitMQMessage) GetConfigurationSetRssWebhookRequest added in v0.0.2

func (x *RabbitMQMessage) GetConfigurationSetRssWebhookRequest() *ConfigurationSetRssWebhookRequest

func (*RabbitMQMessage) GetConfigurationSetServerRequest added in v0.0.2

func (x *RabbitMQMessage) GetConfigurationSetServerRequest() *ConfigurationSetServerRequest

func (*RabbitMQMessage) GetConfigurationSetTwitterWebhookRequest added in v0.0.2

func (x *RabbitMQMessage) GetConfigurationSetTwitterWebhookRequest() *ConfigurationSetTwitterWebhookRequest

func (*RabbitMQMessage) GetJobGetBookAnswer added in v0.0.2

func (x *RabbitMQMessage) GetJobGetBookAnswer() *JobGetBookAnswer

func (*RabbitMQMessage) GetJobGetBookRequest added in v0.0.2

func (x *RabbitMQMessage) GetJobGetBookRequest() *JobGetBookRequest

func (*RabbitMQMessage) GetJobGetUserAnswer added in v0.0.2

func (x *RabbitMQMessage) GetJobGetUserAnswer() *JobGetUserAnswer

func (*RabbitMQMessage) GetJobGetUserRequest added in v0.0.2

func (x *RabbitMQMessage) GetJobGetUserRequest() *JobGetUserRequest

func (*RabbitMQMessage) GetJobSetAnswer added in v0.0.2

func (x *RabbitMQMessage) GetJobSetAnswer() *JobSetAnswer

func (*RabbitMQMessage) GetJobSetRequest added in v0.0.2

func (x *RabbitMQMessage) GetJobSetRequest() *JobSetRequest

func (*RabbitMQMessage) GetLanguage

func (x *RabbitMQMessage) GetLanguage() Language

func (*RabbitMQMessage) GetNewsRSSMessage

func (x *RabbitMQMessage) GetNewsRSSMessage() *NewsRSSMessage

func (*RabbitMQMessage) GetNewsTwitterMessage

func (x *RabbitMQMessage) GetNewsTwitterMessage() *NewsTwitterMessage

func (*RabbitMQMessage) GetPortalPositionAnswer added in v0.0.2

func (x *RabbitMQMessage) GetPortalPositionAnswer() *PortalPositionAnswer

func (*RabbitMQMessage) GetPortalPositionRequest added in v0.0.2

func (x *RabbitMQMessage) GetPortalPositionRequest() *PortalPositionRequest

func (*RabbitMQMessage) GetStatus added in v0.0.2

func (x *RabbitMQMessage) GetStatus() RabbitMQMessage_Status

func (*RabbitMQMessage) GetType

func (*RabbitMQMessage) ProtoMessage

func (*RabbitMQMessage) ProtoMessage()

func (*RabbitMQMessage) ProtoReflect

func (x *RabbitMQMessage) ProtoReflect() protoreflect.Message

func (*RabbitMQMessage) Reset

func (x *RabbitMQMessage) Reset()

func (*RabbitMQMessage) String

func (x *RabbitMQMessage) String() string

type RabbitMQMessage_Status added in v0.0.2

type RabbitMQMessage_Status int32
const (
	RabbitMQMessage_SUCCESS RabbitMQMessage_Status = 0
	RabbitMQMessage_FAILED  RabbitMQMessage_Status = 1
)

func (RabbitMQMessage_Status) Descriptor added in v0.0.2

func (RabbitMQMessage_Status) Enum added in v0.0.2

func (RabbitMQMessage_Status) EnumDescriptor deprecated added in v0.0.2

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

Deprecated: Use RabbitMQMessage_Status.Descriptor instead.

func (RabbitMQMessage_Status) Number added in v0.0.2

func (RabbitMQMessage_Status) String added in v0.0.2

func (x RabbitMQMessage_Status) String() string

func (RabbitMQMessage_Status) Type added in v0.0.2

type RabbitMQMessage_Type

type RabbitMQMessage_Type int32
const (
	RabbitMQMessage_UNKNOWN                                   RabbitMQMessage_Type = 0
	RabbitMQMessage_NEWS_RSS                                  RabbitMQMessage_Type = 100
	RabbitMQMessage_NEWS_TWITTER                              RabbitMQMessage_Type = 101
	RabbitMQMessage_PORTAL_POSITION_REQUEST                   RabbitMQMessage_Type = 200
	RabbitMQMessage_PORTAL_POSITION_ANSWER                    RabbitMQMessage_Type = 201
	RabbitMQMessage_CONFIGURATION_GET_REQUEST                 RabbitMQMessage_Type = 300
	RabbitMQMessage_CONFIGURATION_GET_ANSWER                  RabbitMQMessage_Type = 301
	RabbitMQMessage_CONFIGURATION_SET_SERVER_REQUEST          RabbitMQMessage_Type = 302
	RabbitMQMessage_CONFIGURATION_SET_ALMANAX_WEBHOOK_REQUEST RabbitMQMessage_Type = 303
	RabbitMQMessage_CONFIGURATION_SET_RSS_WEBHOOK_REQUEST     RabbitMQMessage_Type = 304
	RabbitMQMessage_CONFIGURATION_SET_TWITTER_WEBHOOK_REQUEST RabbitMQMessage_Type = 305
	RabbitMQMessage_CONFIGURATION_SET_ANSWER                  RabbitMQMessage_Type = 306
	RabbitMQMessage_JOB_GET_BOOK_REQUEST                      RabbitMQMessage_Type = 400
	RabbitMQMessage_JOB_GET_BOOK_ANSWER                       RabbitMQMessage_Type = 401
	RabbitMQMessage_JOB_GET_USER_REQUEST                      RabbitMQMessage_Type = 402
	RabbitMQMessage_JOB_GET_USER_ANSWER                       RabbitMQMessage_Type = 403
	RabbitMQMessage_JOB_SET_REQUEST                           RabbitMQMessage_Type = 404
	RabbitMQMessage_JOB_SET_ANSWER                            RabbitMQMessage_Type = 405
	RabbitMQMessage_ALIGN_GET_BOOK_REQUEST                    RabbitMQMessage_Type = 500
	RabbitMQMessage_ALIGN_GET_BOOK_ANSWER                     RabbitMQMessage_Type = 501
	RabbitMQMessage_ALIGN_GET_USER_REQUEST                    RabbitMQMessage_Type = 502
	RabbitMQMessage_ALIGN_GET_USER_ANSWER                     RabbitMQMessage_Type = 503
	RabbitMQMessage_ALIGN_SET_REQUEST                         RabbitMQMessage_Type = 504
	RabbitMQMessage_ALIGN_SET_ANSWER                          RabbitMQMessage_Type = 505
)

func (RabbitMQMessage_Type) Descriptor

func (RabbitMQMessage_Type) Enum

func (RabbitMQMessage_Type) EnumDescriptor deprecated

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

Deprecated: Use RabbitMQMessage_Type.Descriptor instead.

func (RabbitMQMessage_Type) Number

func (RabbitMQMessage_Type) String

func (x RabbitMQMessage_Type) String() string

func (RabbitMQMessage_Type) Type

Jump to

Keyboard shortcuts

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