oxynote/server/core/internal/datasource/input.go

package datasource

import "github.com/oxynote/oxynote/server/core/internal/datasource/processor"

// stateInput is an implementation of the Input interface
// that includes credentials.
type stateInput struct {
	url         string
	credentials processor.Credentials
}

// newStateInput creates a new state input with the given credentials.
func newStateInput(
	url string,
	credentials processor.Credentials,
) *stateInput {
	return &stateInput{
		url:         url,
		credentials: credentials,
	}
}

// URL returns the URL of the data source.
func (si *stateInput) URL() string {
	return si.url
}

// Credentials returns the credentials of the data source.
func (si *stateInput) Credentials() processor.Credentials {
	return si.credentials
}