hivelib

package module
v0.7.0 Latest Latest
Warning

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

 Go to latest Published: May 5, 2021 License: GPL-3.0 Imports: 13 Imported by: 0

README

hivelib

Documentation

Index

Constants

View Source 
const (
	ErrorCodeNone                 = 0
	ErrorCodeMalformedJSON        = 1
	ErrorCodeMissingAttr          = 2201
	ErrorCodeRelationshipNotFound = 2202
)
View Source 
const (
	EventTypeDiscordChannelMessage = "discord.message.channel"
	EventTypeDiscordPrivateMessage = "discord.message.private"

	ExchangeName = "events"
)
View Source 
const (
	MimeTypeJson     = "application/json"
	MimeTypeProtobuf = "application/x-protobuf"
)

Variables

View Source 
var (
	Message_Service_name = map[int32]string{
		0: "UNKNOWN",
		1: "DISCORD",
	}
	Message_Service_value = map[string]int32{
		"UNKNOWN": 0,
		"DISCORD": 1,
	}
)

Enum value maps for Message_Service.

View Source 
var File_ism_proto protoreflect.FileDescriptor
View Source 
var File_message_proto protoreflect.FileDescriptor
View Source 
var File_sayer_proto protoreflect.FileDescriptor

Functions

func ErrorMethodNotAllowedHandler added in v0.4.0 

func ErrorMethodNotAllowedHandler() http.Handler

func ErrorNotFoundHandler added in v0.4.0 

func ErrorNotFoundHandler() http.Handler

func ErrorResponseMaker added in v0.4.0 

func ErrorResponseMaker(w http.ResponseWriter, status int, detail string, code int) error

Types

type ErrorObject added in v0.4.0 

type ErrorObject struct {
	Title  string `json:"title,omitempty"`
	Detail string `json:"detail,omitempty"`
	Status string `json:"status,omitempty"`
	Code   string `json:"code,omitempty"`
}

type ErrorPayload added in v0.4.0 

type ErrorPayload struct {
	Error interface{} `json:"error,omitempty"`
}

type EventHandler added in v0.5.0 

type EventHandler interface {
	// Handle is called whenever an event of Type() happens.
	// It is the receivers responsibility to type assert that the interface
	// is the expected struct.
	Handle(*EventsClient, interface{})
}

type EventInterfaceProvider added in v0.5.0 

type EventInterfaceProvider interface {
	// New returns a new instance of the struct this event handler handles.
	// This is called once per event.
	New() interface{}
}

type EventsClient added in v0.5.0 

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

func NewEventsClient added in v0.5.0 

func NewEventsClient(dsn string) (*EventsClient, error)

func (*EventsClient) AddHandler added in v0.5.0 

func (ec *EventsClient) AddHandler(topic string, handler interface{}) error

func (*EventsClient) Close added in v0.5.0 

func (ec *EventsClient) Close()

func (*EventsClient) DiscordChannelMessageEmitter added in v0.5.0 

func (ec *EventsClient) DiscordChannelMessageEmitter(msg *Message) error

func (*EventsClient) DiscordPrivateMessageEmitter added in v0.7.0 

func (ec *EventsClient) DiscordPrivateMessageEmitter(msg *Message) error

func (*EventsClient) Run added in v0.5.0 

func (ec *EventsClient) Run() error

func (*EventsClient) Subscribe added in v0.6.0 

func (ec *EventsClient) Subscribe(topics ...string) error

type Ism 

type Ism struct {
	Id     string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Text   string   `protobuf:"bytes,2,opt,name=text,proto3" json:"text,omitempty"`
	Tts    string   `protobuf:"bytes,3,opt,name=tts,proto3" json:"tts,omitempty"`
	Sayers []*Sayer `protobuf:"bytes,4,rep,name=sayers,proto3" json:"sayers,omitempty"`
	// contains filtered or unexported fields
}

func (*Ism) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use Ism.ProtoReflect.Descriptor instead.

func (*Ism) GetId added in v0.2.0 

func (x *Ism) GetId() string

func (*Ism) GetSayers added in v0.2.0 

func (x *Ism) GetSayers() []*Sayer

func (*Ism) GetText added in v0.2.0 

func (x *Ism) GetText() string

func (*Ism) GetTts added in v0.2.0 

func (x *Ism) GetTts() string

func (*Ism) ProtoMessage added in v0.2.0 

func (*Ism) ProtoMessage()

func (*Ism) ProtoReflect added in v0.2.0 

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

func (*Ism) Reset added in v0.2.0 

func (x *Ism) Reset()

func (*Ism) String added in v0.2.0 

func (x *Ism) String() string

type Message added in v0.5.0 

type Message struct {
	Id             string          `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Service        Message_Service `protobuf:"varint,2,opt,name=service,proto3,enum=hivelib.Message_Service" json:"service,omitempty"`
	Text           string          `protobuf:"bytes,3,opt,name=text,proto3" json:"text,omitempty"`                                           // Message contents
	MeString       string          `protobuf:"bytes,4,opt,name=me_string,json=meString,proto3" json:"me_string,omitempty"`                   // string used to match an @
	ResponseTarget string          `protobuf:"bytes,5,opt,name=response_target,json=responseTarget,proto3" json:"response_target,omitempty"` // Where to direct response back to.
	DirectMessage  bool            `protobuf:"varint,6,opt,name=direct_message,json=directMessage,proto3" json:"direct_message,omitempty"`
	Meta           *anypb.Any      `protobuf:"bytes,7,opt,name=meta,proto3" json:"meta,omitempty"`
	// contains filtered or unexported fields
}

func (*Message) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use Message.ProtoReflect.Descriptor instead.

func (*Message) GetDirectMessage added in v0.5.0 

func (x *Message) GetDirectMessage() bool

func (*Message) GetId added in v0.5.0 

func (x *Message) GetId() string

func (*Message) GetMeString added in v0.5.0 

func (x *Message) GetMeString() string

func (*Message) GetMeta added in v0.5.0 

func (x *Message) GetMeta() *anypb.Any

func (*Message) GetResponseTarget added in v0.5.0 

func (x *Message) GetResponseTarget() string

func (*Message) GetService added in v0.5.0 

func (x *Message) GetService() Message_Service

func (*Message) GetText added in v0.5.0 

func (x *Message) GetText() string

func (*Message) ProtoMessage added in v0.5.0 

func (*Message) ProtoMessage()

func (*Message) ProtoReflect added in v0.5.0 

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

func (*Message) Reset added in v0.5.0 

func (x *Message) Reset()

func (*Message) String added in v0.5.0 

func (x *Message) String() string

type Message_Service added in v0.5.0 

type Message_Service int32
const (
	Message_UNKNOWN Message_Service = 0
	Message_DISCORD Message_Service = 1
)

func (Message_Service) Descriptor added in v0.5.0 

func (Message_Service) Descriptor() protoreflect.EnumDescriptor

func (Message_Service) Enum added in v0.5.0 

func (x Message_Service) Enum() *Message_Service

func (Message_Service) EnumDescriptor deprecated added in v0.5.0 

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

Deprecated: Use Message_Service.Descriptor instead.

func (Message_Service) Number added in v0.5.0 

func (x Message_Service) Number() protoreflect.EnumNumber

func (Message_Service) String added in v0.5.0 

func (x Message_Service) String() string

func (Message_Service) Type added in v0.5.0 

func (Message_Service) Type() protoreflect.EnumType

type Sayer 

type Sayer struct {
	Id   string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Uuid string `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"`
	// contains filtered or unexported fields
}

func (*Sayer) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use Sayer.ProtoReflect.Descriptor instead.

func (*Sayer) GetId added in v0.2.0 

func (x *Sayer) GetId() string

func (*Sayer) GetUuid added in v0.2.0 

func (x *Sayer) GetUuid() string

func (*Sayer) ProtoMessage added in v0.2.0 

func (*Sayer) ProtoMessage()

func (*Sayer) ProtoReflect added in v0.2.0 

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

func (*Sayer) Reset added in v0.2.0 

func (x *Sayer) Reset()

func (*Sayer) String added in v0.2.0 

func (x *Sayer) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.