Documentation
¶
Index ¶
- type Config
- type MinioClient
- func (s *MinioClient) DataIsProxy(data []byte) bool
- func (s *MinioClient) Get(key []byte) ([]byte, error)
- func (s *MinioClient) GetKey(proxyData []byte) []byte
- func (s *MinioClient) Put(key []byte, data []byte) (proxydata []byte, err error)
- func (s *MinioClient) Remove(key []byte) error
- func (s *MinioClient) Run(mainParams *application.MainParams) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct {
Endpoint string `arg:"env:MINIO_ENDPOINT"`
AccessKeyID string `arg:"env:MINIO_ACCESS_KEY"`
SecretAccessKey string `arg:"env:MINIO_SECRET_KEY"`
BucketName string `arg:"env:MINIO_BIG_MSG_BUCKET"`
}
Конфигурация модуля.
type MinioClient ¶
type MinioClient struct {
application.AbstractComponent
// contains filtered or unexported fields
}
func New ¶
func New(config *Config) *MinioClient
func (*MinioClient) DataIsProxy ¶
func (s *MinioClient) DataIsProxy(data []byte) bool
проверка, что принятое сообщение является прокси сообщением
func (*MinioClient) Get ¶
func (s *MinioClient) Get(key []byte) ([]byte, error)
блокирующий метод получения данных
func (*MinioClient) GetKey ¶
func (s *MinioClient) GetKey(proxyData []byte) []byte
Получение ключа из прокси сообщения
func (*MinioClient) Put ¶
func (s *MinioClient) Put(key []byte, data []byte) (proxydata []byte, err error)
блокирующий метод сохранения данных
func (*MinioClient) Run ¶
func (s *MinioClient) Run(mainParams *application.MainParams) error
Запуск клиента в работу. Реализация интерфейса application.Runnable.
Source Files
Click to show internal directories.
Click to hide internal directories.