machine

package
v0.0.0-...-3ee0b18 Latest Latest
Warning

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

 Go to latest Published: Apr 20, 2026 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_search_internal_machine_commands_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type AppendFileCommand 

type AppendFileCommand struct {
	Id          int64  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	UserId      int64  `protobuf:"varint,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	Name        string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	Size        int64  `protobuf:"varint,5,opt,name=size,proto3" json:"size,omitempty"`
	Mime        string `protobuf:"bytes,6,opt,name=mime,proto3" json:"mime,omitempty"`
	Private     bool   `protobuf:"varint,7,opt,name=private,proto3" json:"private,omitempty"`
	CreatedAt   string `protobuf:"bytes,8,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt   string `protobuf:"bytes,9,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

func (*AppendFileCommand) Descriptor deprecated 

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

Deprecated: Use AppendFileCommand.ProtoReflect.Descriptor instead.

func (*AppendFileCommand) GetCreatedAt 

func (x *AppendFileCommand) GetCreatedAt() string

func (*AppendFileCommand) GetDescription 

func (x *AppendFileCommand) GetDescription() string

func (*AppendFileCommand) GetId 

func (x *AppendFileCommand) GetId() int64

func (*AppendFileCommand) GetMime 

func (x *AppendFileCommand) GetMime() string

func (*AppendFileCommand) GetName 

func (x *AppendFileCommand) GetName() string

func (*AppendFileCommand) GetPrivate 

func (x *AppendFileCommand) GetPrivate() bool

func (*AppendFileCommand) GetSize 

func (x *AppendFileCommand) GetSize() int64

func (*AppendFileCommand) GetUpdatedAt 

func (x *AppendFileCommand) GetUpdatedAt() string

func (*AppendFileCommand) GetUserId 

func (x *AppendFileCommand) GetUserId() int64

func (*AppendFileCommand) ProtoMessage 

func (*AppendFileCommand) ProtoMessage()

func (*AppendFileCommand) ProtoReflect 

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

func (*AppendFileCommand) Reset 

func (x *AppendFileCommand) Reset()

func (*AppendFileCommand) String 

func (x *AppendFileCommand) String() string

type AppendMessageCommand 

type AppendMessageCommand struct {
	Id        int64  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	UserId    int64  `protobuf:"varint,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	Text      string `protobuf:"bytes,3,opt,name=text,proto3" json:"text,omitempty"`
	Name      string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	Private   bool   `protobuf:"varint,5,opt,name=private,proto3" json:"private,omitempty"`
	Title     string `protobuf:"bytes,6,opt,name=title,proto3" json:"title,omitempty"`
	CreatedAt string `protobuf:"bytes,7,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt string `protobuf:"bytes,8,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

func (*AppendMessageCommand) Descriptor deprecated 

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

Deprecated: Use AppendMessageCommand.ProtoReflect.Descriptor instead.

func (*AppendMessageCommand) GetCreatedAt 

func (x *AppendMessageCommand) GetCreatedAt() string

func (*AppendMessageCommand) GetId 

func (x *AppendMessageCommand) GetId() int64

func (*AppendMessageCommand) GetName 

func (x *AppendMessageCommand) GetName() string

func (*AppendMessageCommand) GetPrivate 

func (x *AppendMessageCommand) GetPrivate() bool

func (*AppendMessageCommand) GetText 

func (x *AppendMessageCommand) GetText() string

func (*AppendMessageCommand) GetTitle 

func (x *AppendMessageCommand) GetTitle() string

func (*AppendMessageCommand) GetUpdatedAt 

func (x *AppendMessageCommand) GetUpdatedAt() string

func (*AppendMessageCommand) GetUserId 

func (x *AppendMessageCommand) GetUserId() int64

func (*AppendMessageCommand) ProtoMessage 

func (*AppendMessageCommand) ProtoMessage()

func (*AppendMessageCommand) ProtoReflect 

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

func (*AppendMessageCommand) Reset 

func (x *AppendMessageCommand) Reset()

func (*AppendMessageCommand) String 

func (x *AppendMessageCommand) String() string

type AppendThreadCommand 

type AppendThreadCommand struct {
	Id          int64  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	UserId      int64  `protobuf:"varint,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	ParentId    int64  `protobuf:"varint,3,opt,name=parent_id,json=parentId,proto3" json:"parent_id,omitempty"`
	Name        string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	Description string `protobuf:"bytes,5,opt,name=description,proto3" json:"description,omitempty"`
	Private     bool   `protobuf:"varint,6,opt,name=private,proto3" json:"private,omitempty"`
	CreatedAt   string `protobuf:"bytes,7,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt   string `protobuf:"bytes,8,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

func (*AppendThreadCommand) Descriptor deprecated 

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

Deprecated: Use AppendThreadCommand.ProtoReflect.Descriptor instead.

func (*AppendThreadCommand) GetCreatedAt 

func (x *AppendThreadCommand) GetCreatedAt() string

func (*AppendThreadCommand) GetDescription 

func (x *AppendThreadCommand) GetDescription() string

func (*AppendThreadCommand) GetId 

func (x *AppendThreadCommand) GetId() int64

func (*AppendThreadCommand) GetName 

func (x *AppendThreadCommand) GetName() string

func (*AppendThreadCommand) GetParentId 

func (x *AppendThreadCommand) GetParentId() int64

func (*AppendThreadCommand) GetPrivate 

func (x *AppendThreadCommand) GetPrivate() bool

func (*AppendThreadCommand) GetUpdatedAt 

func (x *AppendThreadCommand) GetUpdatedAt() string

func (*AppendThreadCommand) GetUserId 

func (x *AppendThreadCommand) GetUserId() int64

func (*AppendThreadCommand) ProtoMessage 

func (*AppendThreadCommand) ProtoMessage()

func (*AppendThreadCommand) ProtoReflect 

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

func (*AppendThreadCommand) Reset 

func (x *AppendThreadCommand) Reset()

func (*AppendThreadCommand) String 

func (x *AppendThreadCommand) String() string

type AppendTranslationCommand 

type AppendTranslationCommand struct {
	MessageId int64  `protobuf:"varint,1,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	UserId    int64  `protobuf:"varint,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	Lang      string `protobuf:"bytes,3,opt,name=lang,proto3" json:"lang,omitempty"`
	Title     string `protobuf:"bytes,4,opt,name=title,proto3" json:"title,omitempty"`
	Text      string `protobuf:"bytes,5,opt,name=text,proto3" json:"text,omitempty"`
	CreatedAt string `protobuf:"bytes,6,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt string `protobuf:"bytes,7,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

func (*AppendTranslationCommand) Descriptor deprecated 

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

Deprecated: Use AppendTranslationCommand.ProtoReflect.Descriptor instead.

func (*AppendTranslationCommand) GetCreatedAt 

func (x *AppendTranslationCommand) GetCreatedAt() string

func (*AppendTranslationCommand) GetLang 

func (x *AppendTranslationCommand) GetLang() string

func (*AppendTranslationCommand) GetMessageId 

func (x *AppendTranslationCommand) GetMessageId() int64

func (*AppendTranslationCommand) GetText 

func (x *AppendTranslationCommand) GetText() string

func (*AppendTranslationCommand) GetTitle 

func (x *AppendTranslationCommand) GetTitle() string

func (*AppendTranslationCommand) GetUpdatedAt 

func (x *AppendTranslationCommand) GetUpdatedAt() string

func (*AppendTranslationCommand) GetUserId 

func (x *AppendTranslationCommand) GetUserId() int64

func (*AppendTranslationCommand) ProtoMessage 

func (*AppendTranslationCommand) ProtoMessage()

func (*AppendTranslationCommand) ProtoReflect 

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

func (*AppendTranslationCommand) Reset 

func (x *AppendTranslationCommand) Reset()

func (*AppendTranslationCommand) String 

func (x *AppendTranslationCommand) String() string

type ChangeThreadParentCommand 

type ChangeThreadParentCommand struct {
	Id       int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	UserId   int64 `protobuf:"varint,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	ParentId int64 `protobuf:"varint,3,opt,name=parent_id,json=parentId,proto3" json:"parent_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ChangeThreadParentCommand) Descriptor deprecated 

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

Deprecated: Use ChangeThreadParentCommand.ProtoReflect.Descriptor instead.

func (*ChangeThreadParentCommand) GetId 

func (x *ChangeThreadParentCommand) GetId() int64

func (*ChangeThreadParentCommand) GetParentId 

func (x *ChangeThreadParentCommand) GetParentId() int64

func (*ChangeThreadParentCommand) GetUserId 

func (x *ChangeThreadParentCommand) GetUserId() int64

func (*ChangeThreadParentCommand) ProtoMessage 

func (*ChangeThreadParentCommand) ProtoMessage()

func (*ChangeThreadParentCommand) ProtoReflect 

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

func (*ChangeThreadParentCommand) Reset 

func (x *ChangeThreadParentCommand) Reset()

func (*ChangeThreadParentCommand) String 

func (x *ChangeThreadParentCommand) String() string

type DeleteFilesCommand 

type DeleteFilesCommand struct {
	Ids    []int64 `protobuf:"varint,1,rep,packed,name=ids,proto3" json:"ids,omitempty"`
	UserId int64   `protobuf:"varint,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteFilesCommand) Descriptor deprecated 

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

Deprecated: Use DeleteFilesCommand.ProtoReflect.Descriptor instead.

func (*DeleteFilesCommand) GetIds 

func (x *DeleteFilesCommand) GetIds() []int64

func (*DeleteFilesCommand) GetUserId 

func (x *DeleteFilesCommand) GetUserId() int64

func (*DeleteFilesCommand) ProtoMessage 

func (*DeleteFilesCommand) ProtoMessage()

func (*DeleteFilesCommand) ProtoReflect 

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

func (*DeleteFilesCommand) Reset 

func (x *DeleteFilesCommand) Reset()

func (*DeleteFilesCommand) String 

func (x *DeleteFilesCommand) String() string

type DeleteMessageCommand 

type DeleteMessageCommand struct {
	Id     int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	UserId int64 `protobuf:"varint,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteMessageCommand) Descriptor deprecated 

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

Deprecated: Use DeleteMessageCommand.ProtoReflect.Descriptor instead.

func (*DeleteMessageCommand) GetId 

func (x *DeleteMessageCommand) GetId() int64

func (*DeleteMessageCommand) GetUserId 

func (x *DeleteMessageCommand) GetUserId() int64

func (*DeleteMessageCommand) ProtoMessage 

func (*DeleteMessageCommand) ProtoMessage()

func (*DeleteMessageCommand) ProtoReflect 

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

func (*DeleteMessageCommand) Reset 

func (x *DeleteMessageCommand) Reset()

func (*DeleteMessageCommand) String 

func (x *DeleteMessageCommand) String() string

type DeleteThreadCommand 

type DeleteThreadCommand struct {
	Id     int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	UserId int64 `protobuf:"varint,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteThreadCommand) Descriptor deprecated 

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

Deprecated: Use DeleteThreadCommand.ProtoReflect.Descriptor instead.

func (*DeleteThreadCommand) GetId 

func (x *DeleteThreadCommand) GetId() int64

func (*DeleteThreadCommand) GetUserId 

func (x *DeleteThreadCommand) GetUserId() int64

func (*DeleteThreadCommand) ProtoMessage 

func (*DeleteThreadCommand) ProtoMessage()

func (*DeleteThreadCommand) ProtoReflect 

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

func (*DeleteThreadCommand) Reset 

func (x *DeleteThreadCommand) Reset()

func (*DeleteThreadCommand) String 

func (x *DeleteThreadCommand) String() string

type DeleteTranslationCommand 

type DeleteTranslationCommand struct {
	MessageId int64  `protobuf:"varint,1,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	Lang      string `protobuf:"bytes,2,opt,name=lang,proto3" json:"lang,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteTranslationCommand) Descriptor deprecated 

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

Deprecated: Use DeleteTranslationCommand.ProtoReflect.Descriptor instead.

func (*DeleteTranslationCommand) GetLang 

func (x *DeleteTranslationCommand) GetLang() string

func (*DeleteTranslationCommand) GetMessageId 

func (x *DeleteTranslationCommand) GetMessageId() int64

func (*DeleteTranslationCommand) ProtoMessage 

func (*DeleteTranslationCommand) ProtoMessage()

func (*DeleteTranslationCommand) ProtoReflect 

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

func (*DeleteTranslationCommand) Reset 

func (x *DeleteTranslationCommand) Reset()

func (*DeleteTranslationCommand) String 

func (x *DeleteTranslationCommand) String() string

type Dumper 

type Dumper interface {
	Open(ctx context.Context) (ch chan *api.SearchSnapshot, err error)
	Restore(ctx context.Context, user *api.SearchSnapshot) (err error)
	Close() (err error)
}

type FilesRepository 

type FilesRepository interface {
	SaveFile(ctx context.Context, id, userID int64, name, description, mime string, private bool, size int64, createdAt, updatedAt string) (err error)
	DeleteFiles(ctx context.Context, id []int64, userID int64) (err error)
	PublishFiles(ctx context.Context, id []int64, userID int64, updatedAt string) (err error)
	PrivateFiles(ctx context.Context, id []int64, userID int64, updatedAt string) (err error)
}

type Machine 

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

func New 

func New(messagesRepo MessagesRepository, filesRepo FilesRepository, threadsRepo ThreadsRepository,
	translationsRepo TranslationsRepository, dumper Dumper, log *logger.Logger) *Machine

func (*Machine) Apply 

func (f *Machine) Apply(record *raft.Log) interface{}

func (*Machine) Restore 

func (f *Machine) Restore(reader io.ReadCloser) (err error)

func (*Machine) Snapshot 

func (f *Machine) Snapshot() (raft.FSMSnapshot, error)

type MessagesRepository 

type MessagesRepository interface {
	SaveMessage(ctx context.Context, id, userID int64, name, title, text string, private bool, createdAt, updatedAt string) error
	UpdateMessage(ctx context.Context, id, userID int64, name, title, text *string, updatedAt string) error
	PrivateMessages(ctx context.Context, ids []int64, userID int64, updatedAt string) error
	PublishMessages(ctx context.Context, ids []int64, userID int64, updatedAt string) error
	DeleteMessage(ctx context.Context, id, userID int64) error
}

type PrivateFilesCommand 

type PrivateFilesCommand struct {
	Ids       []int64 `protobuf:"varint,1,rep,packed,name=ids,proto3" json:"ids,omitempty"`
	UserId    int64   `protobuf:"varint,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	UpdatedAt string  `protobuf:"bytes,3,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

func (*PrivateFilesCommand) Descriptor deprecated 

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

Deprecated: Use PrivateFilesCommand.ProtoReflect.Descriptor instead.

func (*PrivateFilesCommand) GetIds 

func (x *PrivateFilesCommand) GetIds() []int64

func (*PrivateFilesCommand) GetUpdatedAt 

func (x *PrivateFilesCommand) GetUpdatedAt() string

func (*PrivateFilesCommand) GetUserId 

func (x *PrivateFilesCommand) GetUserId() int64

func (*PrivateFilesCommand) ProtoMessage 

func (*PrivateFilesCommand) ProtoMessage()

func (*PrivateFilesCommand) ProtoReflect 

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

func (*PrivateFilesCommand) Reset 

func (x *PrivateFilesCommand) Reset()

func (*PrivateFilesCommand) String 

func (x *PrivateFilesCommand) String() string

type PrivateMessagesCommand 

type PrivateMessagesCommand struct {
	Ids       []int64 `protobuf:"varint,1,rep,packed,name=ids,proto3" json:"ids,omitempty"`
	UserId    int64   `protobuf:"varint,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	UpdatedAt string  `protobuf:"bytes,3,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

func (*PrivateMessagesCommand) Descriptor deprecated 

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

Deprecated: Use PrivateMessagesCommand.ProtoReflect.Descriptor instead.

func (*PrivateMessagesCommand) GetIds 

func (x *PrivateMessagesCommand) GetIds() []int64

func (*PrivateMessagesCommand) GetUpdatedAt 

func (x *PrivateMessagesCommand) GetUpdatedAt() string

func (*PrivateMessagesCommand) GetUserId 

func (x *PrivateMessagesCommand) GetUserId() int64

func (*PrivateMessagesCommand) ProtoMessage 

func (*PrivateMessagesCommand) ProtoMessage()

func (*PrivateMessagesCommand) ProtoReflect 

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

func (*PrivateMessagesCommand) Reset 

func (x *PrivateMessagesCommand) Reset()

func (*PrivateMessagesCommand) String 

func (x *PrivateMessagesCommand) String() string

type PrivateThreadCommand 

type PrivateThreadCommand struct {
	Id        int64  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	UserId    int64  `protobuf:"varint,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	UpdatedAt string `protobuf:"bytes,3,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

func (*PrivateThreadCommand) Descriptor deprecated 

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

Deprecated: Use PrivateThreadCommand.ProtoReflect.Descriptor instead.

func (*PrivateThreadCommand) GetId 

func (x *PrivateThreadCommand) GetId() int64

func (*PrivateThreadCommand) GetUpdatedAt 

func (x *PrivateThreadCommand) GetUpdatedAt() string

func (*PrivateThreadCommand) GetUserId 

func (x *PrivateThreadCommand) GetUserId() int64

func (*PrivateThreadCommand) ProtoMessage 

func (*PrivateThreadCommand) ProtoMessage()

func (*PrivateThreadCommand) ProtoReflect 

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

func (*PrivateThreadCommand) Reset 

func (x *PrivateThreadCommand) Reset()

func (*PrivateThreadCommand) String 

func (x *PrivateThreadCommand) String() string

type PublishFilesCommand 

type PublishFilesCommand struct {
	Ids       []int64 `protobuf:"varint,1,rep,packed,name=ids,proto3" json:"ids,omitempty"`
	UserId    int64   `protobuf:"varint,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	UpdatedAt string  `protobuf:"bytes,3,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishFilesCommand) Descriptor deprecated 

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

Deprecated: Use PublishFilesCommand.ProtoReflect.Descriptor instead.

func (*PublishFilesCommand) GetIds 

func (x *PublishFilesCommand) GetIds() []int64

func (*PublishFilesCommand) GetUpdatedAt 

func (x *PublishFilesCommand) GetUpdatedAt() string

func (*PublishFilesCommand) GetUserId 

func (x *PublishFilesCommand) GetUserId() int64

func (*PublishFilesCommand) ProtoMessage 

func (*PublishFilesCommand) ProtoMessage()

func (*PublishFilesCommand) ProtoReflect 

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

func (*PublishFilesCommand) Reset 

func (x *PublishFilesCommand) Reset()

func (*PublishFilesCommand) String 

func (x *PublishFilesCommand) String() string

type PublishMessagesCommand 

type PublishMessagesCommand struct {
	Ids       []int64 `protobuf:"varint,1,rep,packed,name=ids,proto3" json:"ids,omitempty"`
	UserId    int64   `protobuf:"varint,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	UpdatedAt string  `protobuf:"bytes,3,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishMessagesCommand) Descriptor deprecated 

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

Deprecated: Use PublishMessagesCommand.ProtoReflect.Descriptor instead.

func (*PublishMessagesCommand) GetIds 

func (x *PublishMessagesCommand) GetIds() []int64

func (*PublishMessagesCommand) GetUpdatedAt 

func (x *PublishMessagesCommand) GetUpdatedAt() string

func (*PublishMessagesCommand) GetUserId 

func (x *PublishMessagesCommand) GetUserId() int64

func (*PublishMessagesCommand) ProtoMessage 

func (*PublishMessagesCommand) ProtoMessage()

func (*PublishMessagesCommand) ProtoReflect 

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

func (*PublishMessagesCommand) Reset 

func (x *PublishMessagesCommand) Reset()

func (*PublishMessagesCommand) String 

func (x *PublishMessagesCommand) String() string

type PublishThreadCommand 

type PublishThreadCommand struct {
	Id        int64  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	UserId    int64  `protobuf:"varint,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	UpdatedAt string `protobuf:"bytes,3,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishThreadCommand) Descriptor deprecated 

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

Deprecated: Use PublishThreadCommand.ProtoReflect.Descriptor instead.

func (*PublishThreadCommand) GetId 

func (x *PublishThreadCommand) GetId() int64

func (*PublishThreadCommand) GetUpdatedAt 

func (x *PublishThreadCommand) GetUpdatedAt() string

func (*PublishThreadCommand) GetUserId 

func (x *PublishThreadCommand) GetUserId() int64

func (*PublishThreadCommand) ProtoMessage 

func (*PublishThreadCommand) ProtoMessage()

func (*PublishThreadCommand) ProtoReflect 

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

func (*PublishThreadCommand) Reset 

func (x *PublishThreadCommand) Reset()

func (*PublishThreadCommand) String 

func (x *PublishThreadCommand) String() string

type RequestType 

type RequestType uint16
const (
	AppendMessageRequest RequestType = iota
	UpdateMessageRequest
	DeleteMessageRequest
	PublishMessagesRequest
	PrivateMessagesRequest
	AppendThreadRequest
	UpdateThreadRequest
	DeleteThreadRequest
	ChangeThreadParentRequest
	PublishThreadRequest
	PrivateThreadRequest
	AppendFileRequest
	DeleteFilesRequest
	PublishFilesRequest
	PrivateFilesRequest
	AppendTranslationRequest
	DeleteTranslationRequest
	UpdateTranslationRequest
)

type ThreadsRepository 

type ThreadsRepository interface {
	SaveThread(ctx context.Context, id, userID, parentID int64, name, description string, private bool, createdAt, updatedAt string) error
	UpdateThread(ctx context.Context, id, userID int64, name, description *string, updatedAt string) error
	DeleteThread(ctx context.Context, id, userID int64) error
	ChangeThreadParent(ctx context.Context, id, userID, parentID int64) error
	PublishThread(ctx context.Context, id, userID int64, updatedAt string) error
	PrivateThread(ctx context.Context, id, userID int64, updatedAt string) error
}

type TranslationsRepository 

type TranslationsRepository interface {
	SaveTranslation(ctx context.Context, userID, messageID int64, lang, title, text string, createdAt, updatedAt string) error
	DeleteTranslation(ctx context.Context, messageID int64, lang string) error
	UpdateTranslation(ctx context.Context, messageID int64, lang string, title, text *string, updatedAt string) error
}

type UpdateMessageCommand 

type UpdateMessageCommand struct {
	Id        int64   `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	UserId    int64   `protobuf:"varint,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	Text      *string `protobuf:"bytes,3,opt,name=text,proto3,oneof" json:"text,omitempty"`
	Name      *string `protobuf:"bytes,4,opt,name=name,proto3,oneof" json:"name,omitempty"`
	Title     *string `protobuf:"bytes,5,opt,name=title,proto3,oneof" json:"title,omitempty"`
	UpdatedAt string  `protobuf:"bytes,6,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateMessageCommand) Descriptor deprecated 

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

Deprecated: Use UpdateMessageCommand.ProtoReflect.Descriptor instead.

func (*UpdateMessageCommand) GetId 

func (x *UpdateMessageCommand) GetId() int64

func (*UpdateMessageCommand) GetName 

func (x *UpdateMessageCommand) GetName() string

func (*UpdateMessageCommand) GetText 

func (x *UpdateMessageCommand) GetText() string

func (*UpdateMessageCommand) GetTitle 

func (x *UpdateMessageCommand) GetTitle() string

func (*UpdateMessageCommand) GetUpdatedAt 

func (x *UpdateMessageCommand) GetUpdatedAt() string

func (*UpdateMessageCommand) GetUserId 

func (x *UpdateMessageCommand) GetUserId() int64

func (*UpdateMessageCommand) ProtoMessage 

func (*UpdateMessageCommand) ProtoMessage()

func (*UpdateMessageCommand) ProtoReflect 

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

func (*UpdateMessageCommand) Reset 

func (x *UpdateMessageCommand) Reset()

func (*UpdateMessageCommand) String 

func (x *UpdateMessageCommand) String() string

type UpdateThreadCommand 

type UpdateThreadCommand struct {
	Id          int64   `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	UserId      int64   `protobuf:"varint,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	Name        *string `protobuf:"bytes,3,opt,name=name,proto3,oneof" json:"name,omitempty"`
	Description *string `protobuf:"bytes,4,opt,name=description,proto3,oneof" json:"description,omitempty"`
	UpdatedAt   string  `protobuf:"bytes,5,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateThreadCommand) Descriptor deprecated 

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

Deprecated: Use UpdateThreadCommand.ProtoReflect.Descriptor instead.

func (*UpdateThreadCommand) GetDescription 

func (x *UpdateThreadCommand) GetDescription() string

func (*UpdateThreadCommand) GetId 

func (x *UpdateThreadCommand) GetId() int64

func (*UpdateThreadCommand) GetName 

func (x *UpdateThreadCommand) GetName() string

func (*UpdateThreadCommand) GetUpdatedAt 

func (x *UpdateThreadCommand) GetUpdatedAt() string

func (*UpdateThreadCommand) GetUserId 

func (x *UpdateThreadCommand) GetUserId() int64

func (*UpdateThreadCommand) ProtoMessage 

func (*UpdateThreadCommand) ProtoMessage()

func (*UpdateThreadCommand) ProtoReflect 

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

func (*UpdateThreadCommand) Reset 

func (x *UpdateThreadCommand) Reset()

func (*UpdateThreadCommand) String 

func (x *UpdateThreadCommand) String() string

type UpdateTranslationCommand 

type UpdateTranslationCommand struct {
	MessageId int64   `protobuf:"varint,1,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	Lang      string  `protobuf:"bytes,2,opt,name=lang,proto3" json:"lang,omitempty"`
	Title     *string `protobuf:"bytes,3,opt,name=title,proto3,oneof" json:"title,omitempty"`
	Text      *string `protobuf:"bytes,4,opt,name=text,proto3,oneof" json:"text,omitempty"`
	UpdatedAt string  `protobuf:"bytes,5,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateTranslationCommand) Descriptor deprecated 

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

Deprecated: Use UpdateTranslationCommand.ProtoReflect.Descriptor instead.

func (*UpdateTranslationCommand) GetLang 

func (x *UpdateTranslationCommand) GetLang() string

func (*UpdateTranslationCommand) GetMessageId 

func (x *UpdateTranslationCommand) GetMessageId() int64

func (*UpdateTranslationCommand) GetText 

func (x *UpdateTranslationCommand) GetText() string

func (*UpdateTranslationCommand) GetTitle 

func (x *UpdateTranslationCommand) GetTitle() string

func (*UpdateTranslationCommand) GetUpdatedAt 

func (x *UpdateTranslationCommand) GetUpdatedAt() string

func (*UpdateTranslationCommand) ProtoMessage 

func (*UpdateTranslationCommand) ProtoMessage()

func (*UpdateTranslationCommand) ProtoReflect 

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

func (*UpdateTranslationCommand) Reset 

func (x *UpdateTranslationCommand) Reset()

func (*UpdateTranslationCommand) String 

func (x *UpdateTranslationCommand) 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.