common

Documentation

Index

• Constants
• Variables
• type LocalService
• type MatchDefinition
  • func (m *MatchDefinition) CachePrefix() string
  • func (m *MatchDefinition) GenerateSocketURL() string
  • func (m *MatchDefinition) Path() string
  • func (m *MatchDefinition) String() string
• type MessagingItem
  • func (i *MessagingItem) Application() string
  • func (i *MessagingItem) Config() *structureSpec.Messaging
  • func (i *MessagingItem) Project() string
• type MessagingMap
• type MessagingMapItem
  • func (mmi *MessagingMapItem) Len() int
  • func (mmi *MessagingMapItem) Matches(channel string) []*structureSpec.Messaging
  • func (mmi *MessagingMapItem) Names() []string
  • func (mmi *MessagingMapItem) Push(project, application string, m *structureSpec.Messaging)

Constants

const ReplaceMe = ""

Variables

var (
	WebSocketFormat   = "ws-%s/%s"
	WebSocketHttpPath = "/ws-{hash}/{channel:.+}"
	Logger            = log.Logger("tau.substrate.service.pubsub")
)

Types

type LocalService

type LocalService interface {
	iface.Service
	Lookup(matcher *MatchDefinition) (picks []iface.Serviceable, err error)
	Context() context.Context
}

type MatchDefinition

type MatchDefinition struct {
	Channel     string
	Project     string
	Application string
	WebSocket   bool
	Commit      string
}

func (*MatchDefinition) CachePrefix

func (m *MatchDefinition) CachePrefix() string

func (*MatchDefinition) GenerateSocketURL

func (m *MatchDefinition) GenerateSocketURL() string

func (*MatchDefinition) Path

func (m *MatchDefinition) Path() string

func (*MatchDefinition) String

func (m *MatchDefinition) String() string

type MessagingItem

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

func (*MessagingItem) Application

func (i *MessagingItem) Application() string

func (*MessagingItem) Config

func (i *MessagingItem) Config() *structureSpec.Messaging

func (*MessagingItem) Project

func (i *MessagingItem) Project() string

type MessagingMap

type MessagingMap struct {
	Function  MessagingMapItem
	WebSocket MessagingMapItem
	HasAny    bool
}

type MessagingMapItem

type MessagingMapItem struct {
	Items []*MessagingItem
}

func (*MessagingMapItem) Len

func (mmi *MessagingMapItem) Len() int

func (*MessagingMapItem) Matches

func (mmi *MessagingMapItem) Matches(channel string) []*structureSpec.Messaging

func (*MessagingMapItem) Names

func (mmi *MessagingMapItem) Names() []string

Used for getting names of messaging channels in tests

func (*MessagingMapItem) Push

func (mmi *MessagingMapItem) Push(project, application string, m *structureSpec.Messaging)