Documentation
¶
Index ¶
- Constants
- type Intermediate
- type Mock
- func (svc *Mock) CacheLoad(w http.ResponseWriter, r *http.Request) (err error)
- func (svc *Mock) CacheStore(w http.ResponseWriter, r *http.Request) (err error)
- func (svc *Mock) DefaultQueue(w http.ResponseWriter, r *http.Request) (err error)
- func (svc *Mock) Home(w http.ResponseWriter, r *http.Request) (err error)
- func (svc *Mock) MockCacheLoad(handler func(w http.ResponseWriter, r *http.Request) (err error)) *Mock
- func (svc *Mock) MockCacheStore(handler func(w http.ResponseWriter, r *http.Request) (err error)) *Mock
- func (svc *Mock) MockDefaultQueue(handler func(w http.ResponseWriter, r *http.Request) (err error)) *Mock
- func (svc *Mock) MockHome(handler func(w http.ResponseWriter, r *http.Request) (err error)) *Mock
- func (svc *Mock) MockNoQueue(handler func(w http.ResponseWriter, r *http.Request) (err error)) *Mock
- func (svc *Mock) NoQueue(w http.ResponseWriter, r *http.Request) (err error)
- func (svc *Mock) OnShutdown(ctx context.Context) (err error)
- func (svc *Mock) OnStartup(ctx context.Context) (err error)
- type Service
- func (svc *Service) CacheLoad(w http.ResponseWriter, r *http.Request) (err error)
- func (svc *Service) CacheStore(w http.ResponseWriter, r *http.Request) (err error)
- func (svc *Service) DefaultQueue(w http.ResponseWriter, r *http.Request) (err error)
- func (svc *Service) Home(w http.ResponseWriter, r *http.Request) (err error)
- func (svc *Service) Init(initializer func(svc *Service) (err error)) *Service
- func (svc *Service) NoQueue(w http.ResponseWriter, r *http.Request) (err error)
- func (svc *Service) OnShutdown(ctx context.Context) (err error)
- func (svc *Service) OnStartup(ctx context.Context) (err error)
- type ToDo
Constants ¶
const ( Hostname = messagingapi.Hostname Version = 229 )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Intermediate ¶ added in v1.22.0
Intermediate extends and customizes the generic base connector.
func NewIntermediate ¶ added in v1.22.0
func NewIntermediate(impl ToDo) *Intermediate
NewIntermediate creates a new instance of the intermediate.
type Mock ¶
type Mock struct {
*Intermediate
// contains filtered or unexported fields
}
Mock is a mockable version of the microservice, allowing functions, event sinks and web handlers to be mocked.
func (*Mock) CacheStore ¶ added in v1.22.0
CacheStore executes the mock handler.
func (*Mock) DefaultQueue ¶ added in v1.22.0
DefaultQueue executes the mock handler.
func (*Mock) MockCacheLoad ¶ added in v1.22.0
func (svc *Mock) MockCacheLoad(handler func(w http.ResponseWriter, r *http.Request) (err error)) *Mock
MockCacheLoad sets up a mock handler for CacheLoad.
func (*Mock) MockCacheStore ¶ added in v1.22.0
func (svc *Mock) MockCacheStore(handler func(w http.ResponseWriter, r *http.Request) (err error)) *Mock
MockCacheStore sets up a mock handler for CacheStore.
func (*Mock) MockDefaultQueue ¶ added in v1.22.0
func (svc *Mock) MockDefaultQueue(handler func(w http.ResponseWriter, r *http.Request) (err error)) *Mock
MockDefaultQueue sets up a mock handler for DefaultQueue.
func (*Mock) MockNoQueue ¶ added in v1.22.0
func (svc *Mock) MockNoQueue(handler func(w http.ResponseWriter, r *http.Request) (err error)) *Mock
MockNoQueue sets up a mock handler for NoQueue.
func (*Mock) OnShutdown ¶ added in v1.22.0
OnShutdown is called when the microservice is shut down.
type Service ¶
type Service struct {
*Intermediate // IMPORTANT: Do not remove
}
Service implements the messaging.example microservice.
The Messaging microservice demonstrates service-to-service communication patterns.
func (*Service) CacheLoad ¶
CacheLoad looks up an element in the distributed cache of the microservice.
func (*Service) CacheStore ¶
CacheStore stores an element in the distributed cache of the microservice.
func (*Service) DefaultQueue ¶
DefaultQueue demonstrates how the DefaultQueue subscription option is used to create a unicast request/response communication pattern. Only one of the instances of this microservice will respond to each request.
func (*Service) Home ¶
Home demonstrates making requests using multicast and unicast request/response patterns.
func (*Service) NoQueue ¶
NoQueue demonstrates how the NoQueue subscription option is used to create a multicast request/response communication pattern. All instances of this microservice will respond to each request.
func (*Service) OnShutdown ¶
OnShutdown is called when the microservice is shut down.
type ToDo ¶ added in v1.22.0
type ToDo interface {
OnStartup(ctx context.Context) (err error)
OnShutdown(ctx context.Context) (err error)
Home(w http.ResponseWriter, r *http.Request) (err error) // MARKER: Home
NoQueue(w http.ResponseWriter, r *http.Request) (err error) // MARKER: NoQueue
DefaultQueue(w http.ResponseWriter, r *http.Request) (err error) // MARKER: DefaultQueue
CacheLoad(w http.ResponseWriter, r *http.Request) (err error) // MARKER: CacheLoad
CacheStore(w http.ResponseWriter, r *http.Request) (err error) // MARKER: CacheStore
}
ToDo is implemented by the service or mock. The intermediate delegates handling to this interface.
Source Files
Directories