broker

Documentation

Overview

Package broker

Copyright 2022 Jellyfish message broker
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
    http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.

Package broker

Copyright 2022 Jellyfish message broker
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
    http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.

Package broker

Copyright 2022 Jellyfish message broker
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
    http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.

Package broker

Copyright 2022 Jellyfish message broker
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
    http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.

Package broker

Copyright 2022 Jellyfish message broker
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
    http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.

Package broker

Copyright 2022 Jellyfish message broker
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
    http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.

Package broker

Copyright 2022 Jellyfish message broker
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
    http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.

Index

• type Broker
  • func NewBroker() *Broker
  • func (b *Broker) Read(name TopicName) ([]byte, error)
  • func (b *Broker) Write(name TopicName, payload []byte) error
• type Handler
  • func NewHandler(conn net.Conn, broker *Broker, pp *Partition) *Handler
  • func (h *Handler) Do(ctx context.Context)
• type Listener
  • func New(config *config.Config) (*Listener, error)
  • func (l *Listener) Broadcast(ctx context.Context) error
  • func (l *Listener) Close() error
• type Partition
  • func NewPartition(timeout time.Duration, connections []string) (*Partition, error)
  • func (p *Partition) AskByPeers(ctx context.Context, m *messages.Partition) error
• type Topic
• type TopicName

Types

type Broker

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

func NewBroker

func NewBroker() *Broker

func (*Broker) Read

func (b *Broker) Read(name TopicName) ([]byte, error)

func (*Broker) Write

func (b *Broker) Write(name TopicName, payload []byte) error

type Handler

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

func NewHandler

func NewHandler(conn net.Conn, broker *Broker, pp *Partition) *Handler

func (*Handler) Do

func (h *Handler) Do(ctx context.Context)

type Listener

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

func New

func New(config *config.Config) (*Listener, error)

func (*Listener) Broadcast

func (l *Listener) Broadcast(ctx context.Context) error

func (*Listener) Close

func (l *Listener) Close() error

type Partition

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

func NewPartition

func NewPartition(timeout time.Duration, connections []string) (*Partition, error)

func (*Partition) AskByPeers

func (p *Partition) AskByPeers(ctx context.Context, m *messages.Partition) error

type Topic

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

type TopicName

type TopicName string