minioclient

Documentation

Index

• type Config
• type MinioClient
  • func New(config *Config) *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

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) Remove

func (s *MinioClient) Remove(key []byte) error

удаление данных

func (*MinioClient) Run

func (s *MinioClient) Run(mainParams *application.MainParams) error

Запуск клиента в работу. Реализация интерфейса application.Runnable.