googlesheets

Documentation

Index

• type Client
• type Config
• type Credentials
• type GoogleSheetsProducer
  • func NewProducer(destination *backendconfig.DestinationT, o common.Opts) (*GoogleSheetsProducer, error)
  • func (*GoogleSheetsProducer) Close() error
  • func (producer *GoogleSheetsProducer) Produce(jsonData json.RawMessage, _ interface{}) (statusCode int, respStatus, responseMessage string)
• type TestConfig

Types

type Client

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

type Config

type Config struct {
	Credentials string              `json:"credentials"`
	SheetId     string              `json:"sheetId"`
	SheetName   string              `json:"sheetName"`
	EventKeyMap []map[string]string `json:"eventKeyMap"`
	DestID      string              `json:"destId"`
	TestConfig  TestConfig          `json:"testConfig"`
}

type Credentials

type Credentials struct {
	Email      string `json:"client_email"`
	PrivateKey string `json:"private_key"`
	TokenUrl   string `json:"token_uri"`
}

type GoogleSheetsProducer

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

func NewProducer

func NewProducer(destination *backendconfig.DestinationT, o common.Opts) (*GoogleSheetsProducer, error)

NewProducer creates a producer based on destination config

func (*GoogleSheetsProducer) Close

func (*GoogleSheetsProducer) Close() error

func (*GoogleSheetsProducer) Produce

func (producer *GoogleSheetsProducer) Produce(jsonData json.RawMessage, _ interface{}) (statusCode int, respStatus, responseMessage string)

type TestConfig

type TestConfig struct {
	Endpoint     string `json:"endpoint"`
	AccessToken  string `json:"accessToken"`
	RefreshToken string `json:"refreshToken"`
}