msg

Documentation

Index

• type Config
  • func NewConfig(format string, validate bool, dest string) *Config
  • func (c *Config) IsSourceJSON() bool
  • func (c *Config) RunValidation() error
• type Request
• type Response
  • func NewResponse(eventID string) *Response
• type Service
  • func New(config *Config, fs afs.Service) Service
  • func Singleton(config *Config) Service

Types

type Config

type Config struct {
	SourceFormat string
	Validate     bool
	DestURL      string
}

func NewConfig

func NewConfig(format string, validate bool, dest string) *Config

NewConfig return a config

func (*Config) IsSourceJSON

func (c *Config) IsSourceJSON() bool

IsSourceJSON returns true if source format is json

func (*Config) RunValidation

func (c *Config) RunValidation() error

type Request

type Request struct {
	EventID string
	Data    []byte `json:"data"`
}

Request represents a service request

type Response

type Response struct {
	Status  string
	Error   string
	EventID string
	Size    int
	URL     string
}

Response represents a response

func NewResponse

func NewResponse(eventID string) *Response

NewResponse creates a response

type Service

type Service interface {
	Proxy(context.Context, *Request) *Response
}

Service service to proxy pubsub topic payload to google storage with or without validation

func New

func New(config *Config, fs afs.Service) Service

New create a service service

func Singleton

func Singleton(config *Config) Service

Singleton returns new service for env key