datasource

Documentation

Index

• type ConcreteSlackClient
  • func NewConcreteSlackClient(token string) *ConcreteSlackClient
  • func (c *ConcreteSlackClient) GetConversationHistory(params *slack.GetConversationHistoryParameters) (*slack.GetConversationHistoryResponse, error)
  • func (c *ConcreteSlackClient) GetConversationRepliesContext(ctx context.Context, params *slack.GetConversationRepliesParameters) ([]slack.Message, bool, string, error)
• type DatasourceMock
  • func (_m *DatasourceMock) GetData(currentState types.State) ([]types.Document, types.State, error)
  • func (_m *DatasourceMock) GetID() string
• type Manager
  • func NewDatasourceManager(storage storage.Storage, logger *logrus.Logger, aclManager auth.ACLManager) *Manager
  • func (dm *Manager) RegisterRoutes(r chi.Router)
• type SlackClient
• type SlackClientMock
  • func NewSlackClient(t interface{ ... }) *SlackClientMock
  • func (_m *SlackClientMock) GetConversationHistory(params *slack.GetConversationHistoryParameters) (*slack.GetConversationHistoryResponse, error)
  • func (_m *SlackClientMock) GetConversationRepliesContext(ctx context.Context, params *slack.GetConversationRepliesParameters) ([]slack.Message, bool, string, error)
• type SlackDatasource
  • func NewSlackDatasource(config types.DatasourceConfig, client SlackClient, logger *logrus.Logger) (*SlackDatasource, error)
  • func (s *SlackDatasource) GetData(ctx context.Context, state types.DatasourceState) ([]types.Document, types.DatasourceState, error)
  • func (s *SlackDatasource) GetID() uuid.UUID
  • func (s *SlackDatasource) Validate() error
• type SlackDatasourceError
  • func (e *SlackDatasourceError) Error() string

Types

type ConcreteSlackClient

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

ConcreteSlackClient is a concrete implementation of the Slack client interface

func NewConcreteSlackClient

func NewConcreteSlackClient(token string) *ConcreteSlackClient

NewConcreteSlackClient creates a new Slack client with the given token

func (*ConcreteSlackClient) GetConversationHistory

func (c *ConcreteSlackClient) GetConversationHistory(params *slack.GetConversationHistoryParameters) (*slack.GetConversationHistoryResponse, error)

GetConversationHistory is a wrapper around slack.GetConversationHistory

func (*ConcreteSlackClient) GetConversationRepliesContext

func (c *ConcreteSlackClient) GetConversationRepliesContext(ctx context.Context, params *slack.GetConversationRepliesParameters) ([]slack.Message, bool, string, error)

GetConversationRepliesContext is a wrapper around slack.GetConversationRepliesContext

type DatasourceMock

type DatasourceMock struct {
	mock.Mock
}

func (*DatasourceMock) GetData

func (_m *DatasourceMock) GetData(currentState types.State) ([]types.Document, types.State, error)

func (*DatasourceMock) GetID

func (_m *DatasourceMock) GetID() string

type Manager

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

func NewDatasourceManager

func NewDatasourceManager(storage storage.Storage, logger *logrus.Logger, aclManager auth.ACLManager) *Manager

func (*Manager) RegisterRoutes

func (dm *Manager) RegisterRoutes(r chi.Router)

type SlackClient

type SlackClient interface {
	GetConversationHistory(params *slack.GetConversationHistoryParameters) (*slack.GetConversationHistoryResponse, error)
	GetConversationRepliesContext(ctx context.Context, params *slack.GetConversationRepliesParameters) (msgs []slack.Message, hasMore bool, nextCursor string, err error)
}

SlackClient is an interface for a Slack client

type SlackClientMock

type SlackClientMock struct {
	mock.Mock
}

func NewSlackClient

func NewSlackClient(t interface {
	mock.TestingT
	Cleanup(func())
}) *SlackClientMock

func (*SlackClientMock) GetConversationHistory

func (_m *SlackClientMock) GetConversationHistory(params *slack.GetConversationHistoryParameters) (*slack.GetConversationHistoryResponse, error)

func (*SlackClientMock) GetConversationRepliesContext

func (_m *SlackClientMock) GetConversationRepliesContext(ctx context.Context, params *slack.GetConversationRepliesParameters) ([]slack.Message, bool, string, error)

type SlackDatasource

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

SlackDatasource is a datasource for fetching messages from a Slack channel

func NewSlackDatasource

func NewSlackDatasource(config types.DatasourceConfig, client SlackClient, logger *logrus.Logger) (*SlackDatasource, error)

NewSlackDatasource creates a new Slack datasource with the given configuration, client, and logger

func (*SlackDatasource) GetData

func (s *SlackDatasource) GetData(ctx context.Context, state types.DatasourceState) ([]types.Document, types.DatasourceState, error)

GetData fetches new messages from the Slack channel and returns them as documents

func (*SlackDatasource) GetID

func (s *SlackDatasource) GetID() uuid.UUID

GetID returns the UUID of the Slack datasource

func (*SlackDatasource) Validate

func (s *SlackDatasource) Validate() error

Validate validates the Slack datasource configuration

type SlackDatasourceError

type SlackDatasourceError struct {
	Op  string
	Err error
}

SlackDatasourceError is an error type for Slack datasource operations

func (*SlackDatasourceError) Error

func (e *SlackDatasourceError) Error() string